卡夫卡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>