内容简介：一个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的消费模式
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
Imperfect C++中文版
威尔逊 / 荣耀、刘未鹏 / 人民邮电出版社 / 2006-1 / 75.0
汇集实用的C++编程解决方案，C++虽然是一门非凡的语言，但并不完美。Matthew Wilson使用C++十年有余，其间发现C++存在一些固有的限制，需要一些颇具技术性的工作进行弥补。本书不仅指出了C++的缺失，更为你编写健壮、灵活、高效、可维护的代码提供了实用的技术和工具。Wilson向你展示了如何克服C++的复杂性，穿越C++庞大的范式阵列。夺回对代码的控制权，从而获得更理想的结果。一起来看看 《Imperfect C++中文版》 这本书的介绍吧!
