内容简介：一个topic创建了几个partition，启动consumer的时候，只会消费一个partition，消费完了后，会把这个consumer给关闭掉。再启动consumer时，还是只会消费上次消费的那个partition。中间没有任何报错。consumer启动时，只会消费一个partition，然后不能关闭consumer，然后在进行consumer.poll的时候，就可以从其他partition消费了。就算consumer不关闭，偶尔也会从一个分区读取数据，consumer，timeout的时候，cons
一个topic创建了几个partition，启动consumer的时候，只会消费一个partition，消费完了后，会把这个consumer给关闭掉。再启动consumer时，还是只会消费上次消费的那个partition。中间没有任何报错。
1，产生这个问题的原因
consumer启动时，只会消费一个partition，然后不能关闭consumer，然后在进行consumer.poll的时候，就可以从其他partition消费了。
就算consumer不关闭，偶尔也会从一个分区读取数据，consumer，timeout的时候，consumer会自启动，这个时候，也只会从一个分区读取
2，partition和consumer对应规则，总结出来一句话。
consumer对partition，是一对一，一对多都可以
partition对consumer，只能是一对一
如果consumer启动数，大于partition数，肯定有consumer消费不到数据的。
关于网上有的说只消费一个partition，根kafka-clients包版本有关，试了二个版本，发现根版本没关系。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
- 消费端如何保证消息队列MQ的有序消费
- 《吊打面试官》系列-分布式事务、重复消费、顺序消费
- 十一贝：航延险智能判定，公平消费环境惠及消费者
- Kafka消费者的偏移量和高级/简单消费者
- RocketMQ 实战：一个新的消费组初次启动时从何处开始消费呢？
- RocketMQ的消费模式
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
