内容简介：一个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的消费模式
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
JavaScript精粹
爱德华兹 / 高铁军 / 人民邮电出版社 / 2007-6 / 49.00元
《JavaScript 精粹》主要介绍JavaScript应用中一些常见的问题及其解决方法，从最基础的数字、字符串、数组到进阶的DOM、表单验证、cookie，再到较为高级的Ajax，书中均有涉及。《JavaScript 精粹》覆盖现在非常流行和通用的技术，提出很多出现频率较高的Web开发常见问题，并提供了大量的技巧和解决方案，具有很强的实用性和通用性，书中的代码也具有很强的兼容性。《JavaSc......一起来看看 《JavaScript精粹》 这本书的介绍吧!
