消费者承诺补偿,但未通过/v2/kafka/(集群)/消费者列出

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

我设置了一个burrow安装并指向我的kafka服务器(1个代理和1个zookeeper)。当我调用/v2/kafka/kafka1/consumer时,我得到的响应是:没有消费者。
{"error": false,"message": "consumer list returned","consumers": [],"request": {"url": "/v2/kafka/local/consumer/","host": "", "cluster": "local","group": "","topic": ""}} my burrow.cfg显示为

[general]
        logdir=burrowlogs
        logconfig=config/logging.cfg
        pidfile=burrow.pid
        client-id=burrow-lagchecker
        group-blacklist=^(console-consumer-|python-kafka-consumer-).*$

        [zookeeper]
        hostname=
        port=2181
        timeout=6
        lock-path=/burrow/notifier

        [kafka "local"]
        broker=
        broker-port=9092
        zookeeper=
        zookeeper-port=2181
        zookeeper-path=/
        offsets-topic=__consumer_offsets

        [storm "local"]
        #zookeeper=zkhost01.example.com
        #zookeeper=zkhost02.example.com
        #zookeeper=zkhost03.example.com
        #zookeeper-port=2181
        #zookeeper-path=/kafka-cluster/stormconsumers

        [tickers]
        broker-offsets=60

        [lagcheck]
        intervals=10
        expire-group=604800

        [httpserver]
        server=on
        port=8080

        [smtp]
        server=mailserver.example.com
        port=25
        from=burrow-noreply@example.com
        template=config/default-email.tmpl

        [email "bofh@example.com"]
        group=local,critical-consumer-group
        group=local,other-consumer-group
        interval=60

        [httpnotifier]
        url=http://notification.server.example.com:9000/v1/alert
        interval=60
        extra=app=burrow
        extra=tier=STG
        template-post=config/default-http-post.tmpl
        template-delete=config/default-http-delete.tmpl
        timeout=5
        keepalive=30

        My burrow.out is

        Started Burrow at June 30, 2016 at 3:07pm (UTC)
        2016/06/30 15:10:27 http: multiple response.WriteHeader calls
        2016/06/30 15:10:29 http: multiple response.WriteHeader calls
        2016/06/30 15:10:38 http: multiple response.WriteHeader calls
        2016/06/30 15:10:39 http: multiple response.WriteHeader calls
        2016/06/30 15:10:40 http: multiple response.WriteHeader calls
        2016/06/30 15:10:41 http: multiple response.WriteHeader calls
        2016/06/30 15:10:42 http: multiple response.WriteHeader calls
        2016/06/30 15:10:44 http: multiple response.WriteHeader calls
        2016/06/30 15:10:45 http: multiple response.WriteHeader calls
        2016/06/30 15:10:45 http: multiple response.WriteHeader calls
        2016/06/30 15:10:47 http: multiple response.WriteHeader calls

我使用的是Kafka版本0.10.0。
my offset.storage=Kafka。
我知道集群连接到消费者并正在处理消息。所有其他端点(不在消费者级别)似乎都可以正常工作。

mqkwyuun

mqkwyuun1#

这个问题解决了。只需在my burrow.cfg中添加zookeeper offset=true这将解决在zookeeper中存储Kafka主题的偏移详细信息的问题。

相关问题