Kafka系统学习（5）

(4) offset存储机制

Consumer在从broker读取消息后，可以选择commit，该操作会在Kafka中保存该Consumer 在该 Partition中读取的消息的offset。该Consumer下一次再读该Partition时会从下一条开始读取。通过这一特性可以保证同一消费者从Kafka中不会重复消费数据。

(5) Consumer group：每个Consumer都属于一个Consumer group，每条消息只能被Consumer group中的一个Consumer消费，但可以被多个Consumer group消费。即组间数据是共享的，组内数据是竞争的。如图所示：

Kafka

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。