kafka-delete-records.sh¶

用法:

bin/kafka-delete-records.sh --bootstrap-server 10.0.55.229:9092,10.0.55.229:9093,10.0.55.229:9094 \
    --offset-json-file offset.json

offset.json文件内容:

{
    "partitions": [{
        "topic": "afei",
        "partition": 3,
        "offset": 10
    }],
    "version": 1
}

执行结果如下，表示删除afei这个topic下分区为3的offset少于10的消息日志（不会删除offset=10的消息日志）:

Executing records delete operation
Records delete operation completed:
partition: afei-3   low_watermark: 10