消費者コミットオフセット/ v2/kafka /（クラスタ）/コンシューマ

Question

私はバーローインストールを設定し、私のKafkaサーバーを指しています（1ブローカーと1飼い）。/ v2/kafka/kafka1 /消費者、私は応答を得る、いいえ 消費者。

すなわち{"error": false,"message": "consumer list returned","consumers": [],"request": {"url": "/v2/kafka/local/consumer/","host": "", "cluster": "local","group": "","topic": ""}}

私burrow.cfgは、私はカフカのバージョン0.10.0を使用しています

 [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 

として示されています。

私のoffset.storage = kafka。

私は、クラスタがコンシューマに接続されており、メッセージを処理していることを知っています。他のすべてのエンドポイントは、消費者レベルではなく、正常に動作しているようです。

Answer 1

この問題は解決されました。私のburrow.cfgにzookeeper-offset = trueを追加するだけで、カフカのトピックのオフセット情報を動物園で保存している場合、この問題は解決します。