骑猫猫的鱼
这家伙太懒，什么都没留下
这家伙太懒，什么都没留下
kafka客户端如果用的是默认的话，没有修改默认分区发送规则，那应该是平均分布到6个分区上的。
从代码上看不出来，你是一个消费者，还是三个消费者。
基于你的描述，无法真正确认是否只集中到了某个分区，你可以使用kafka自带的命令来确认：
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
来自：kafka命令大全
如果区分真的只发送到了1分区，那你重点检查你的发送逻辑，而不需要关注消费者。
