这家伙太懒,什么都没留下
不是轮流,在正常情况下是固定的。
跟topic的分区数有关。
比如,你的topic有3个分区,那么你的3个消费者每人会固定消费其中1个分区的消息。如果你的topic有2个分区,那么你其中一个消费者永远也拿不到消息,直到有其他的消费者故障了。
查询确认一下就知道了:
## 新消费者列表查询 bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list ## 显示某个消费组的消费详情(0.10.1.0版本+) bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
来自:kafka命令大全
ps:有问题可以到问题专区提问。
博主我刚刚学习kafka,请教一个问题,kafkaf服务端是两个节点集群部署的,我用idea写了两个消费者客户端程序,这两个消费者属于同一个消费组,而且订阅的是同一个主题mytopic(两个分区),我在服务端通过produce的shell命令在该主题下投递了一条消息,为什么我idea两个消费端都收到了消息呢?我看官网文档说主题的每个分区,消费组中只有其中一个消费者来消费消息,为什么我这同一个消费组两个消费者都收到了消息呢?请帮我解答下,谢谢大佬