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
查询后正常删除
版权归原作者 谷隐凡二 所有, 如有侵权,请联系我们删除。