0
在我使用golang客戶端commitoffset後立即執行。 https://github.com/Shopify/sarama卡夫卡消費羣過期了嗎？
./kafka-consumer-offset-checker.sh --zookeeper=localhost:2181 --topic=my-replicated-topic --group=ib --broker-info
Group Topic Pid Offset logSize Lag Owner
ib my-replicated-topic 0 12 12 0 none
BROKER INFO
1 -> localhost:9093
但是，幾分鐘後，我運行相同的檢查命令。
./kafka-consumer-offset-checker.sh --zookeeper=localhost:2181 --topic=my-replicated-topic --group=ib --broker-info
Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/ib/offsets/my-replicated-topic/0.
而且我檢查zookeeper時，節點在任何時候都不存在，即使檢查器正確列出了偏移量。
薩拉馬承諾：23d523386ce0c886e56c9faf1b9c78b07e5b8c90 卡夫卡0.8.2.1 golang 1.3
卡夫卡服務器配置：
broker.id=1
port=9093
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/tmp/kafka-logs-1
num.partitions=1
num.recovery.threads.per.data.dir=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
log.cleaner.enable=false
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=6000
在我看來，消費者羣體得到過期。我如何讓消費者羣體持續存在？
所有者「無」似乎不正確 - 你能告訴我們更多關於您的操作系統，以及如何創建的主題？我懷疑這個問題更多的是關於系統環境的設置，而不是關於你使用Sarama的問題。 – snwight
@snwight我用[鏈接]（http://kafka.apache.org/documentation.html#introduction）'bin/kafka-topics.sh --describe --zookeeper localhost：2181 - 話題my-replicated-topic'我的操作系統是Ubuntu 12.04。它讓我感到困擾，我沒有明確地創建消費者組，而是通過將它放入commitoffset api調用來隱式創建它。 – onfire
你如何開始動物園管理員？ 你如何檢查該節點是否存在？ 您可以運行bin/zkCli.sh並執行 ls/consumers/ib/offset/my-replicated-topic/0 輸出是什麼？ – kostya