topic日誌清理
server.properties：
log.cleanup.policy=delete (預設)
1. 按時間維度進行kafka日誌清理
log.retention.hours=1
log.retention.minutes=60
log.retention.ms=3600000
2. 按空間維度進行kafka日誌清理
log.retention.bytes=1073741824
無論時間還是空間維度，只要滿足其中乙個log就會被清理。
一小時後發現log已經被清除。
kafka消費之kafka檢視topic是否有資料
配置config檔案為 server.properties 指令碼在 kafka bin路徑下 啟動kafka kafka server start.sh config server.properties 1 dev null 2 1 kafka server start.sh檢視已建立的topic...
Kafka建立topic節點
進入kafka根目錄，建立kafka topic節點id與vfdtbuilddata vfdtclassifydata vfdtevaldata 若已建好則不必再建 具體的建立topic語句為 bin kafka topics.sh create zookeeper localhost 2181 r...
kafka刪除新建topic
原理翻譯可參考 刪除kafka的topic，參照 1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeepe...