kafka 中若禁用自动提交且不手动提交偏移量，消费者重启后将重复消费未提交偏移的消息；在多消费者组内，未提交的偏移不会触发再均衡重分配，因此其他消费者不会接管该消息——重投递仅发生在消费者实例故障恢复或重启时。
kafka 中若禁用自动提交且不手动提交偏移量，消费者重启后将重复消费未提交偏移的消息；在多消费者组内，未提交的偏移不会触发再均衡重分配，因此其他消费者不会接管该消息——重投递仅发生在消费者实例故障恢复或重启时。
在 Kafka 的消费模型中，“消息重投递”（redelivery）并非由服务端主动触发，而是由偏移量（offset）提交状态与消费者生命周期共同决定的结果。你配置了 enable.auto.commit=false 且全程未调用 commitSync() 或 commitAsync()，这意味着：所有已拉取但未显式提交偏移的消息，其消费进度永远不会被 Kafka 记录。
? 关键行为解析
单消费者场景：只要该消费者进程持续运行（即使长时间不提交），Kafka 会认为该分区的消费仍在进行中。此时即使消息已被处理，只要偏移未提交，下次 poll() 仍从上一次提交位置（初始为 auto.offset.reset=latest 所指定的最新位点）开始拉取——注意：由于你设为 latest，首次启动时本就不会读到历史消息；但若改为 earliest，则每次重启都会从头开始消费全部未提交过的消息。
多消费者同 Group 场景：Kafka 的再均衡（rebalance）不以消息是否被 ack 为依据，而以消费者心跳超时或主动退出为触发条件。假设 consumer-1 正常运行但始终不提交偏移，它会持续持有其分配的分区（如 topic-0），consumer-2 即使加入也无法获得该分区——除非 consumer-1 崩溃、网络断开或超过 session.timeout.ms（默认 45s）未发送心跳，才会触发再均衡，此时分区可能被重新分配给 consumer-2，但 consumer-2 仍会从该分区最后一次成功提交的 offset 开始消费（即 0，因从未提交），而非从 consumer-1 停止处继续。
⚠️ 注意事项与最佳实践
- max.poll.records=1 并不能保证“每条消息必须处理完再拉下一条”，它只限制单次 poll() 返回的最大记录数；真正控制处理粒度的是是否提交偏移。
- 若业务要求“至少一次”（at-least-once）语义，请在消息处理成功后立即同步提交：
try { process(record); // 业务逻辑 consumer.commitSync(); // 确保偏移提交成功后再进入下一轮 poll } catch (Exception e) { logger.error("Processing failed", e); // 可选择重试、死信投递或抛异常终止循环 } - 避免在循环内无条件 poll() 而不处理异常或心跳超时风险——长时间阻塞（如 process() 耗时 > max.poll.interval.ms，默认 5 分钟）会导致消费者被踢出群组，引发非预期再均衡。
✅ 总结
Kafka 本身不提供“未 ack 消息超时重发”机制（区别于 RabbitMQ 的 nack + TTL）。所谓“重投递”，本质是消费者重启后从上次提交 offset 处（或 auto.offset.reset 策略）重新开始拉取。因此，可靠的消息处理必须配套严谨的偏移管理策略：
✅ 显式提交（推荐 commitSync() 用于关键路径）
✅ 合理设置 session.timeout.ms 和 max.poll.interval.ms
✅ 结合幂等性设计（如业务主键去重）应对重复消费
只有理解 Kafka 的偏移驱动模型，才能真正掌控消息交付语义。
