每个发布的消息（假设消息是压缩的）是否都有一个唯一的偏移量#分配，并且在给定的分区内保持顺序和增量？另外，偏移序列是否有可能自行重置，也就是说它可以从0开始？
hof1towb1#
官方文件非常清楚：对于每个主题，kafka集群都维护一个分区日志，如下所示：每个分区都是一个有序的、不可变的记录序列，它不断地附加到结构化提交日志中。分区中的每个记录都被分配了一个称为偏移量的顺序id号，该偏移量唯一地标识分区中的每个记录。消费者甚至从一开始就能够从特定的偏移量中读取：要重置特定消费群体的偏移，可以使用以下命令：
kafka-consumer-groups --bootstrap-server localhost:9092 --group my-group --reset-offsets --to-earliest --all-topics --execute
1条答案
按热度按时间hof1towb1#
官方文件非常清楚：
对于每个主题，kafka集群都维护一个分区日志，如下所示：
每个分区都是一个有序的、不可变的记录序列，它不断地附加到结构化提交日志中。分区中的每个记录都被分配了一个称为偏移量的顺序id号，该偏移量唯一地标识分区中的每个记录。
消费者甚至从一开始就能够从特定的偏移量中读取：
要重置特定消费群体的偏移，可以使用以下命令：