我设置了一个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。
我知道集群连接到消费者并正在处理消息。所有其他端点(不在消费者级别)似乎都可以正常工作。
1条答案
按热度按时间mqkwyuun1#
这个问题解决了。只需在my burrow.cfg中添加zookeeper offset=true这将解决在zookeeper中存储Kafka主题的偏移详细信息的问题。