内容简介：一个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的消费模式
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
jQuery实战（第2版）
[美]Bear Bibeault、[美]Yehuda Katz / 三生石上 / 人民邮电出版社 / 2012-3 / 69.00元
jQuery 是目前最受欢迎的JavaScript/Ajax 库之一，能用最少的代码实现最多的功能。本书全面介绍jQuery 知识，展示如何遍历HTML 文档、处理事件、执行动画、给网页添加Ajax 以及jQuery UI 。书中紧紧地围绕“用实际的示例来解释每一个新概念”这一宗旨，生动描述了jQuery 如何与其他工具和框架交互以及如何生成jQuery 插件。 本书适合各层次Web 开发人......一起来看看 《jQuery实战（第2版）》 这本书的介绍吧!
JSON 在线解析
在线 JSON 格式化工具
RGB CMYK 转换工具
RGB CMYK 互转工具