kafka消费组id未按预期工作

rn0zuynd  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(281)

我是Apache·Kafka的新人。当我通过http://kafka.apache.org/quickstart Kafka2.12-2.2.0的最新版本。我有个问题,一个人想不出来。
问题是,在我的笔记本电脑上,我创建了3个代理来模拟集群的情况。
每个代理都有自己的服务器属性文件。我对每个服务器属性文件做了以下更改,并保留了其他默认值。

broker.id=1      (server2: broker.id=2;  server3: broker.id=3)

listeners=PLAINTEXT://127.0.0.1:9092   (server2: 127.0.0.1:9023;  server3: 127.0.0.1:9004) 

log.dirs=/tmp/kafka-logs   (server2: /tmp/kafka-logs-2; server3: /tmp/kafka-logs-3)

num.partitions=3   (for all servers)

offsets.topic.replication.factor=3  (for all servers)

在我启动zk和这3个代理之后,我(可以)在任何代理上创建一个带有3个分区的主题“testtopic”

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic TestTopic

然后我使用下面的命令启动同一组“rickygroup”中的3个消费者。
//消费者一号

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic TestTopic —group.id rickygroup —group.name rickygroup

//消费者2

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9093 --from-beginning --topic TestTopic —group.id rickygroup —group.name rickygroup

//消费者三

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9094 --from-beginning --topic TestTopic —group.id rickygroup —group.name rickygroup

现在,我使用另一个终端发布一些关于主题“testtopic”的消息。问题是,上述3个消费者都会收到完全相同的信息。我的理解是3个消费者应该消费所有的信息冷漠,而不是相同的。否则,消费群体表现为重复消费而非平衡消费。
我对消费群体概念有没有误解?或者我做错了什么?

lsmd5eda

lsmd5eda1#

控制台使用者使用 --group (有两个破折号),不是 -group.id 和/或 -group.name ,它们不是解析的选项。

相关问题