0


kafka通过命令行删除指定topic下所有records

1、kafka环境配置

由于在windows环境下,在kafka官网下载下来Apache Kafka需要将E:\kafka_2.12-3.3.1\bin\windows下的路径加入到环境变量中,方便直接使用kafka工具,其他系统直接使用bin下的工具即可:

2、配置kafka指定topic的json文件,命名为delete.json,此文件放在任意位置都可:

可以查询到目标topic有多少个partions的详情:

kafka-topics.bat --bootstrap-server 10.10.10.1:29094 --describe --topic EVENT.record
#topic为指定topic,partition为目标topic下指定的partion的编号有几个,可以通过查询partions来查看下,offset为指定偏移量,-1为删除所有:
{
    "partitions":[
        {
            "topic":"aa",
            "partition": 0,
            "offset":-1
        },
        {
            "topic":"aa",
            "partition": 1,
            "offset":-1
        }
    ],
    "version":1
}

3、调用kafka删除topic消息工具执行kafka的删除消息命令命令:

kafka-delete-records.bat --bootstrap-server kafka-0.icos.city:29094 --offset-json-file E:\kafka_2.12-3.3.1\delete.json

查询后正常删除

标签: kafka java 分布式

本文转载自: https://blog.csdn.net/m0_37570494/article/details/128724726
版权归原作者 谷隐凡二 所有, 如有侵权,请联系我们删除。

“kafka通过命令行删除指定topic下所有records”的评论:

还没有评论