| 前提 | 消费组处于 inactive(无活跃消费者) |
|---|---|
| 目标 | --to-earliest / --to-latest / --to-offset / --shift-by / --to-datetime |
| 执行 | 先 --dry-run 预览,确认后加 --execute |
重置到最早(含演练)
重置到最早(含演练)
# 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-earliest --dry-run
# 3) 执行
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group order-consumer --topic orders \
--reset-offsets --to-earliest --execute重置到最早前先评估重放量:几天的消息全量重放会打满下游库;生产环境优先按时间点重置。