卡夫卡:抵消序列

拉曼

是否会为每个发布的消息(假设消息已压缩)分配一个唯一的偏移号,并在给定分区内保持顺序和递增?另外,offset#序列是否有可能会自行重置,也就是说它可以从0开始?

Giorgos Myrianthous

官方文档对此非常清楚:

对于每个主题,Kafka集群都会维护一个分区日志,如下所示:

在此处输入图片说明

每个分区都是有序的,不可变的记录序列,这些记录连续地附加到结构化的提交日志中。分别为分区中的记录分配了一个顺序ID号,称为偏移量,它唯一地标识分区中的每个记录。

消费者甚至可以从一开始就从特定的偏移量中进行读取:

在此处输入图片说明

为了重置特定使用者组的偏移量,您可以使用以下方法:

kafka-consumer-groups --bootstrap-server localhost:9092 --group my-group --reset-offsets --to-earliest --all-topics --execute

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章