位移重置是什么
位移重置把消费组的已提交位移改到另一个位置：可以改到最早、最新、某个具体数值、某个时间点，或按条数前后平移。它用于补数、跳过坏数据、以及在新组上线前设定起点。工具默认只做演练并打印将要写入的位移，必须显式加 --execute 才真正提交。
什么时候用
下游数据被误删需要重放时、某段时间的消息因解析错误被跳过需要补跑时、以及流量切换后要避免新组从历史开始消费时。共同点是：重置前的位移必须可控、可回退，因此执行顺序永远是「先停消费、再看清现状、然后重置」。
基本信息
| 前提 | 消费组处于 inactive（无活跃成员），否则被拒绝 |
|---|---|
| 目标参数 | --to-earliest / --to-latest / --to-offset / --shift-by / --to-datetime |
| 执行方式 | 默认演练打印，加 --execute 才提交 |
| 粒度 | 可按主题或按分区单独重置 |
| 影响面 | 只改位移，不删除消息，也不触发下游重算 |
重置方式怎么选
| 参数 | 位移落点 | 适用 |
|---|---|---|
| --to-earliest | 分区最早可用位置 | 全量重放，需评估数据量 |
| --to-latest | 直接跳到末尾 | 放弃历史，仅消费新数据 |
| --to-datetime | 某个时间点之后的第一条 | 定位到故障开始时刻，最常用 |
| --to-offset | 指定的具体位移值 | 精确补某个区间 |
| --shift-by | 在当前位移上前后平移 N 条 | 跳过少量坏数据，负数表示回退 |
典型使用场景
- 下游表被误删或误刷，需要按时间点重放一段消息
- 某段消息格式错误导致解析失败，修正后回退位点重跑
- 新消费组上线，把起点设为最新，避免把历史全量消费一遍
- 并行验证新老链路：让新组从同一起点消费，对比输出是否一致
- 确认坏数据位置后，用 --shift-by 跳过这几十条消息
重置到指定时间点（含演练）
重置到指定时间点（含演练）
# 1) 确认组已停产，没有活跃成员
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--describe --group order-consumer --state
# 2) 演练：只打印每个分区将要写入的新位移，不提交
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group order-consumer --topic orders \
--reset-offsets --to-datetime 2026-10-11T00:00:00.000 --dry-run
# 3) 数字确认无误后执行
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group order-consumer --topic orders \
--reset-offsets --to-datetime 2026-10-11T00:00:00.000 --execute
# 4) 复核：位移应停在目标时间点附近，lag 反映待补数据量
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-consumer重置到某个时间点时，Kafka 按消息的时间戳查找边界；如果生产端时间戳不可靠（例如由上游系统写入的业务时间），实际落点会与预期相差较大，执行前务必用演练输出逐分区核对。
重置到 earliest 前先估算重放量：几天的消息全量重放会打满下游数据库，生产环境优先按时间点重置，只补真正需要的那一段。