只删某个主题的位移
--delete-offsets 只清理指定消费组在指定主题上的位移记录，组本身以及该组在其他主题上的位移都不受影响。它适合两类场景：某个主题确定要彻底重放，或某个主题的订阅已经废弃需要清理。删除后该组再次订阅这个主题时会按 auto.offset.reset 决定起点，默认从最新开始。
基本信息
| 命令 | --delete-offsets --group <组> --topic <主题> |
|---|---|
| 前提 | 消费组无活跃成员 |
| 影响范围 | 仅该组在该主题上的位移 |
| 起点规则 | 重新订阅时按 auto.offset.reset 生效 |
典型使用场景
- 单主题彻底重放：只重置一个主题，不影响同组的其他订阅
- 废弃订阅清理：某主题下线后清掉残留位移，保持组信息干净
- 主题重建后的收尾：删除后重建同名主题，旧位移已无意义
- 排查「某主题没数据」：确认位移是否被清、起点是否变成 latest
- 分区改造后重新对齐：配合显式重置把起点挪到需要的位置
删位移与显式重置
删位移与显式重置
# 1) 确认组内没有活跃消费者（有成员时命令会失败）
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-consumer
# 2) 只删除 orders 这个主题上的位移
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--delete-offsets --group order-consumer --topic orders
# 3) 需要从最早开始时显式重置，不要依赖默认值
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group order-consumer --topic orders --reset-offsets --to-earliest --execute位移操作对照
| 操作 | 命令参数 | 影响范围 |
|---|---|---|
| 删除整个组 | --delete --group | 组信息与该组所有主题位移 |
| 删单主题位移 | --delete-offsets --topic | 该组在该主题上的位移 |
| 重置到最早 | --reset-offsets --to-earliest | 按参数确定的起点 |
| 重置到指定时间 | --reset-offsets --to-datetime | 按时间定位起点 |
位移删除后客户端断开重连时会按 auto.offset.reset 决定起点（默认 latest），重放量要提前评估；生产操作前建议先记录当前位移，便于回退。
只删位移不删组时，监控里仍然看得到组名，容易误以为链路正常；验证要看 LAG 是否发生跳变，而不是只看组是否存在。
删除位移不会影响该组其他主题的订阅：多主题共用一个组的链路里，可以只对出问题的那个主题做重置，其余主题继续按原位移消费，影响面比删组小得多。