Kafka之消费信息保存在哪


了消费位移对应的消息内容格式,上面是消息的 key ,下面是消息的 value
可以看到 key value 中都包含了 version 宇段,这个用来标识具体的 key value 的版本信
息,不同的版本对应的内容格式可能并不相同 。就目前版本而言, key 和 value的 version
都为1。 key 中除了 version 字段还有 group、topic、partition 字段,分别表示消费组
groupId、主题名称和分区编号。虽然 key 中包含了4 个字段,但最终确定这条消息所要存储
的分区还是根据单独的 group 字段来计算的,这样就可以保证消费位移信息与消费组对应的
GroupCoordinator 处于同一个 broker 节点上,省去了中间轮转的开销,这一点与消费组的元数
据信息的存储是一样的
  
 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM