我是Kafka的新手,正在建立一个elk堆栈来收集jmx度量和日志文件,以便进行分析和报告。
目前,我已经设置了我的日志库来收集KafkaMBean,其模式如下:
{
"object_name" : "kafka.*:type=*,name=*,topic=*,partition=*"
},
{
"object_name" : "kafka.*:type=*,name=*,topic=*"
},
{
"object_name" : "kafka.*:type=*,name=*"
},
{
"object_name" : "kafka.*:type=*,client-id=*"
},
{
"object_name" : "kafka.*:type=*,name=*,clientId=*,brokerHost=*,brokerPort=*"
},
{
"object_name" : "kafka.*:type=*,name=*,clientId=*"
},
{
"object_name" : "kafka.*:type=*,broker-id=*,fetcher-id=*"
},
{
"object_name" : "kafka.*:type=*,client-id=*"
}
我的问题是我错过了一切 kafka.consumer
当我在rmi端口上登录到jconsole时,我没有看到 kafka.consumer
我也在那里。
我对jmx/mbeans的东西和Kafka都不熟悉,所以我是不是在找合适的地方 kafka.consumer
韵律学?我目前确实有活跃的生产商和消费者参与集群。
1条答案
按热度按时间iqjalb3h1#
这个
kafka.consumer
mbean只存在于使用者进程本身,而不是kafka代理进程。请注意,如果您使用的是java以外的客户机库(例如kafkapython),那么mbean将不存在。这是apache文档中关于代理/消费者/生产者上提供的mbean的官方部分,这里是一个来自合流kafka文档的稍微容易阅读的版本。