两个消费端,但是总有一个消费端接收不到kafka的消息

守护轻鸟 发表于: 2017-12-04   最后更新时间: 2017-12-04 23:05:12   4,230 游览

我的brokder只有一台,分区设置的是2个,我启动两个消费端来接收kafka发送的消息,这两个消费端的group_id是一样的,但是两台消费端起来之后,每次只有一台能接收到消息,

发表于 2017-12-04
添加评论

新消费者列表查询(支持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条命令帮你排查问题。

守护轻鸟 -> 半兽人 7年前

不行,问题原因没有找到,我通过命令看:我每个消费者的消费线程都是1

半兽人 -> 守护轻鸟 7年前

显示某个消费组的消费详情发下结果我看看

守护轻鸟 -> 半兽人 7年前

我想在请教个问题,每个消费端都对应一个分区吗?比方说我有两个消费者的话,是不是分区必须设置成两个,这样才能让两个消费者都接收到kafka消息呢。反之如果我两个消费者,一个分区,这样是不是肯定有一个消费者会接收不到消息

半兽人 -> 守护轻鸟 7年前

是的,我在入门那一章节有详细介绍的。

你的答案

查看kafka相关的其他问题或提一个您自己的问题