java kafka消费者中seek()重置位移需先完成分区分配再调用，必须关闭自动提交、显式手动提交，并在onpartitionsassigned中重设以应对rebalance，seek后须立即poll才生效。
在 Java Kafka 消费者中用 seek() 重置位移，核心是“先分配分区、再精准定位”，不能跳过分区分配直接 seek。它适用于需要精确回溯到某条消息（比如 offset=1234）、某个时间点，或自定义逻辑控制消费起点的场景。
必须关闭自动提交
自动提交会覆盖手动 seek 的位置，导致重溯失败。务必显式关闭：
props.put("enable.auto.commit", "false");- 后续需配合
commitSync()或commitAsync()手动提交偏移量
确保消费者已分配到分区
seek() 只对当前已分配的分区生效。新启动的消费者初始 assignment 为空，必须先触发一次 poll() 完成分区分配：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 调用
consumer.poll(Duration.ofMillis(100))直到consumer.assignment()返回非空集合 - 不能依赖单次 poll——网络延迟或协调器响应慢时，assignment 可能仍为空
- 建议加简单循环判断，避免
IllegalStateException: No current assignment for partition
按不同需求调用对应 seek 方法
根据目标位移类型选择合适 API：
- 回溯到指定 offset：
consumer.seek(new TopicPartition("topic-a", 0), 1234L); - 从头开始消费：
consumer.seekToBeginning(Collections.singleton(new TopicPartition("topic-a", 0))); - 跳到最新位置（跳过积压）：
consumer.seekToEnd(Collections.singleton(new TopicPartition("topic-a", 0))); - 按时间戳定位（需配合
offsetsForTimes()）：
先查时间对应的 offset 映射，再对每个分区调用seek(tp, offset)
seek 后立即 poll 才能生效
seek 只是设置内部指针，不触发实际拉取。下一次 poll() 才会从新位置开始读取消息：
- seek 后不要立刻处理业务逻辑，应紧接着调用
poll() - 若 poll 前又发生 rebalance，seek 位置可能丢失——建议在
ConsumerRebalanceListener的onPartitionsAssigned中重新 seek - 对多个分区操作时，逐一分区 seek 更稳妥，避免遗漏
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
