Spring Kafka如何让消费者从Topic起始位置重新读取消息？

问题原因 #

auto-offset-reset=earliest 仅在消费者组无历史偏移量记录时生效。若group-1之前已提交过偏移量（哪怕是误操作创建的），Kafka会直接沿用已有偏移量，不会触发从头消费。

操作步骤 #

1. 检查目标组的偏移量状态 #

用Kafka命令行工具查询group-1的偏移量信息：

kafka-consumer-groups.sh --bootstrap-server host --describe --group group-1

若输出中目标topic存在CURRENT-OFFSET，说明该组已有历史偏移量。

2. 删除目标组的偏移量记录 #

执行命令删除group-1的偏移量：

kafka-consumer-groups.sh --bootstrap-server host --delete --group group-1

再次执行查询命令，确认该组已被移除。

3. 重启Spring Boot应用 #

重启后，group-1作为全新的消费者组连接Kafka，因无历史偏移量，会触发auto-offset-reset=earliest，从topic起始位置消费。

额外检查项 #

• 确认kafkaListenerContainerFactory未覆盖偏移量重置配置：检查容器工厂代码，确保没有将AUTO_OFFSET_RESET_CONFIG设置为latest或其他值，保证与配置文件的earliest一致。
• 验证目标topic存在历史消息，若topic本身无消息，自然看不到从头消费的效果。

内容的提问来源于stack exchange，提问作者user1555190