卡夫卡gruop消費者

Question

我已經在消費羣體使用以下命令

ldnpsr000001131$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic rent_test --property group.id=rent_test auto.commit.enable=true auto.commit.interval.ms=100 

開始了消費者按照我的理解，上述命令將創建一個名爲rent_test一個消費羣體，並commtted每100毫秒偏移。但是，當我試圖列出所有的用戶組時，組「rent_test」沒有出現。

ldnpsr000001131$ bin/kafka-consumer-groups.sh --list --zookeeper localhost:2181 
console-consumer-68623 
console-consumer-18287 
console-consumer-45392 
test 
console-consumer-9009 
KafkaMirror-test 
console-consumer-25049 
kafka-mirror 
console-consumer-61946 
console-consumer-940 
console-consumer-11318 
KafkaMirror 
console-consumer-43035 
console-consumer-99202 
consumer-test 
console-consumer-42642 
console-consumer-19085 
console-consumer-7142 
KafkaMirror-test-1 
console-consumer-82299 
console-consumer-81448 
console-consumer-26487 
console-consumer-71474 
flink 
console-consumer-4692 

請指教？

Answer 1

如果您使用的是舊用戶，請不要在property中指定group.id。在0.10.0.1中，你必須在消費者配置文件中指定它並設置consumer.config：

bin/kafka-console-consumer.sh --zookeeper zkHost:2181 --topic test-topic --consumer.config <config file path>