| 输入 | offset-json-file：{topic, partition, offset} |
|---|---|
| 语义 | 删除小于指定 offset 的所有记录 |
| 影响 | 低水位提升；消费者从更早位移读取会报越界 |
删除指定分区历史消息
删除指定分区历史消息
cat > delete.json <<'EOF'
{"version": 1, "partitions": [{"topic": "orders", "partition": 0, "offset": 500}]}
EOF
kafka-delete-records.sh --bootstrap-server localhost:9092 \
--offset-json-file delete.json删除前确认没有消费者需要重放这段数据；对压实主题效果受清理策略限制，先在测试主题验证。