kafka刪除topic消息的三種方式
方法一：快速配置刪除法（確保topic數(shù)據(jù)不要了）
1.kafka啟動之前，在server.properties配置delete.topic.enable=true
2.執(zhí)行命令bin/kafka-topics.sh --delete --topic test --zookeeper zk:2181或者使用kafka-manager集群管理工具刪除
注意：如果kafka啟動之前沒有配置delete.topic.enable=true，topic只會標(biāo)記為marked for deletion，加上配置，重啟kafka，之前的topick就真正刪除了。
方法二：設(shè)置刪除策略（確保topic數(shù)據(jù)不要了）
1.kafka啟動之前，在server.properties配置
#日志清理策略選擇有：delete和compact主要針對過期數(shù)據(jù)的處理，或是日志文件達(dá)到限制的額度，會被 topic創(chuàng)建時的指定參數(shù)覆蓋
log.cleanup.policy = delete
#注意:下面有兩種配置，一種是基于時間的策略，另種是基于日志文件大小的策略，兩種策略同是配置的話，只要滿足其中種策略，則觸發(fā)Log刪除的操作。刪除操作總是先刪除最舊的日志消息在Kafka中保存的時間，4小時之前的1og， 可以被刪除掉，根據(jù)policy處理數(shù)據(jù)。
log.retention.hours=4
#當(dāng)剩余空間低于log.retention.bytes字節(jié)，則開始刪除
log.retention.bytes=37580963840
#每隔1000ms, logcleaner線程將檢查一次，看是否符合上述保留策略的消息可以被刪除
log.retention.check.interval.ms=1000
方法三：手動刪除法（不推薦）（確保topic數(shù)據(jù)不要了）
前提：不允許更改server.properties配置
1.刪除zk下面topic（test）
啟動bin/zkCli.sh
ls /brokers/topics
rmr /brokers/topics/test
ls /brokers/topics
查topic是否刪除：bin/kafka-topics.sh --list --zookeeper zk:2181
2.刪除各broker下topic數(shù)據(jù)，默認(rèn)目錄為/tmp/kafka-logs文章來源：http://www.zghlxwxcb.cn/news/detail-600208.html
原文鏈接：https://blog.csdn.net/yiyihuazi/article/details/113103290文章來源地址http://www.zghlxwxcb.cn/news/detail-600208.html
到了這里，關(guān)于kafka刪除topic消息的三種方式的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
