我是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个消费者应该消费所有的信息冷漠,而不是相同的。否则,消费群体表现为重复消费而非平衡消费。
我对消费群体概念有没有误解?或者我做错了什么?
1条答案
按热度按时间lsmd5eda1#
控制台使用者使用
--group
(有两个破折号),不是-group.id
和/或-group.name
,它们不是解析的选项。