我的brokder只有一台,分区设置的是2个,我启动两个消费端来接收kafka发送的消息,这两个消费端的group_id是一样的,但是两台消费端起来之后,每次只有一台能接收到消息,
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group test这2条命令帮你排查问题。
不行,问题原因没有找到,我通过命令看:我每个消费者的消费线程都是1
显示某个消费组的消费详情发下结果我看看
我想在请教个问题,每个消费端都对应一个分区吗?比方说我有两个消费者的话,是不是分区必须设置成两个,这样才能让两个消费者都接收到kafka消息呢。反之如果我两个消费者,一个分区,这样是不是肯定有一个消费者会接收不到消息
是的,我在入门那一章节有详细介绍的。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
新消费者列表查询(支持0.9版本+)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
显示某个消费组的消费详情(仅支持offset存储在zookeeper上的)
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group test
这2条命令帮你排查问题。
不行,问题原因没有找到,我通过命令看:我每个消费者的消费线程都是1
显示某个消费组的消费详情发下结果我看看
我想在请教个问题,每个消费端都对应一个分区吗?比方说我有两个消费者的话,是不是分区必须设置成两个,这样才能让两个消费者都接收到kafka消息呢。反之如果我两个消费者,一个分区,这样是不是肯定有一个消费者会接收不到消息
是的,我在入门那一章节有详细介绍的。
你的答案