收集kafka.mbean

0yg35tkg  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(339)

我是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 韵律学?我目前确实有活跃的生产商和消费者参与集群。

iqjalb3h

iqjalb3h1#

这个 kafka.consumer mbean只存在于使用者进程本身,而不是kafka代理进程。请注意,如果您使用的是java以外的客户机库(例如kafkapython),那么mbean将不存在。
这是apache文档中关于代理/消费者/生产者上提供的mbean的官方部分,这里是一个来自合流kafka文档的稍微容易阅读的版本。

相关问题