为什么消费者不使用所有分区

nbysray5  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(183)

集群设置:kafka-0.8.2版本3 kafka和3个zookeeper服务器。
使用者配置:

zookeeper.connect:localhost:2181,localhost:2181,localhost:2181
group.id:testerGroup
zookeeper.session.timeout.ms:6000
zookeeper.sync.time.ms:200
auto.commit.interval.ms:1000

主题:topic1我正在通过java代码运行高级使用者。我的主题有2个分区(0和1)。我生成了1000个数据,分区0容纳500个数据,分区1容纳500个数据。我只收到分区0的数据,没有收到分区1的数据。
在使用Kafka偏移监视器进行检查时,第1部分数据被认为是滞后的。
为什么分区1数据被认为是滞后的而分区0提供数据。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题