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查询后正常删除
文章来源：https://www.toymoban.com/news/detail-620485.html
文章来源地址https://www.toymoban.com/news/detail-620485.html
到了这里，关于kafka通过命令行删除指定topic下所有records的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
