通过 Reactor-Kafka 的 addAssignListener 在分区分配时调用 seekToEnd()，可确保每次服务重启后从最新偏移量开始消费，既保留原消费者组 ID，又避免积压消息干扰业务逻辑。
通过 reactor-kafka 的 addassignlistener 在分区分配时调用 seektoend()，可确保每次服务重启后从最新偏移量开始消费，既保留原消费者组 id，又避免积压消息干扰业务逻辑。
在基于 Spring Boot 与 Reactor-Kafka 的响应式 Kafka 消费场景中，一个常见但关键的需求是：服务重启后不处理历史积压消息，只消费重启之后新产生的消息，同时继续使用原有的消费者组（consumer group）。这看似与 Kafka 默认的“按提交位点恢复”行为相悖，但完全可通过 Reactor-Kafka 提供的生命周期钩子优雅实现。
核心原理在于：Kafka 消费者在加入消费者组并完成分区分配（partition assignment）后、开始拉取消息前，有一个精确可控的时机——即 assign 事件触发时——允许我们主动重置每个已分配分区的消费位置。此时调用 ReceiverPartition.seekToEnd()，即可将该分区的起始读取位置强制设为当前最新偏移量（即 end offset），从而跳过所有已有消息。
以下为完整实现方案：
@Bean
public ReactiveKafkaConsumerTemplate<UUID, MyEvent> createConsumer(@Autowired KafkaProperties properties) {
Map<String, Object> consumerProps = new HashMap<>(properties.buildConsumerProperties());
// 显式设置 auto.offset.reset=latest（虽非必需，但作为兜底策略推荐保留）
consumerProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
return new ReactiveKafkaConsumerTemplate<>(
ReceiverOptions.<UUID, MyEvent>create(consumerProps)
.subscription(List.of("MY-TOPIC"))
// ✅ 关键配置：在分区分配完成后，对每个分区执行 seekToEnd()
.addAssignListener(partitions ->
partitions.forEach(ReceiverPartition::seekToEnd))
);
}⚠️ 注意事项：
addAssignListener是 Reactor-Kafka 特有的高级 API，必须配合ReactiveKafkaConsumerTemplate使用；Spring Kafka 的@KafkaListener不支持此机制。seekToEnd()仅影响本次分配到的分区，且仅在下一次poll()前生效，因此必须在assign阶段调用，而非subscribe或启动时。- 若消费者组此前已提交过 offset，
auto.offset.reset=latest在首次启动时有效，但重启后无效；而seekToEnd()则每次分配都强制生效，彻底覆盖历史位点，这才是真正可靠的解决方案。- 该方式不会改变消费者组 ID，因此不影响 Kafka 端的组协调、再平衡或监控指标（如
__consumer_offsets中的记录仍归属同一 group）。
最后，在 ApplicationReadyEvent 中启动消费链路时，无需额外干预：
@EventListener(ApplicationReadyEvent.class)
public void listen() {
consumerTemplate
.receiveAutoAck()
.concatMap(record -> handleEvent(record.key(), record.value())
.onErrorResume(e -> {
log.error("Failed to handle event", e);
return Mono.empty();
}))
.subscribe();
}总结：要实现“同组重启即跳过积压”，不应依赖 auto.offset.reset（它仅作用于无提交位点的初始场景），而应利用 Reactor-Kafka 的 addAssignListener + seekToEnd() 组合，在每次分区分配时动态重置消费起点。这是一种轻量、精准、符合响应式语义的最佳实践。
