apache-kafka - Kafka：偏移序列

Question

发布的每条消息（假设消息被压缩）是否都会分配一个唯一的偏移量，并在给定分区内保持顺序和增量？此外，偏移#序列是否有可能自行重置，这意味着它可以从 0 开始？

标签： apache-kafka

Answer 1

官方文档对此非常清楚：

对于每个主题，Kafka 集群维护一个分区日志，如下所示：

每个分区都是一个有序的、不可变的记录序列，不断地附加到一个结构化的提交日志中。每个分区中的记录都分配有一个称为偏移量的顺序 id 号，它唯一地标识分区内的每个记录。

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

为了重置特定消费者组的偏移量，您可以使用以下命令：

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