| 命令 | --delete-offsets --group <组> --topic <主题> |
|---|---|
| 前提 | 消费组无活跃成员 |
| 效果 | 该组在该主题上的位移删除，其他主题不受影响 |
删除指定主题位移
删除指定主题位移
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--delete-offsets --group order-consumer --topic orders
# 再消费时位移策略生效（默认 latest）
# 需要从最早开始时，要么显式重置，要么临时把 auto.offset.reset 设为 earliest位移删除后如果客户端断开重连，会按 auto.offset.reset 从头或从最新开始，重放量提前评估。