進入kafka根目錄，建立kafka topic節點id與vfdtbuilddata、vfdtclassifydata、vfdtevaldata（若已建好則不必再建），具體的建立topic語句為：
bin/kafka-topics.sh--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1--topic vfdtbuilddata
bin/kafka-topics.sh--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1--topic vfdtclassifydata
bin/kafka-topics.sh--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1--topic vfdtevaldata
輸入zkcli.sh進入zookeepr，對建立的kafka topic建立節點與id（若已建好則不必再建），具體建立節點與id語句為：
create/vfdtbuilddata 1
create /vfdtbuilddata /id 1
create /vfdtclassifydata 1
create /vfdtclassifydata /id 1
create /vfdtevaldata 1
create /vfdtevaldata /id 1
此時輸入ls /可看到建立的節點。
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的topic，參照 1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeepe...
kafka刪除topic資料
生產環境中，有乙個topic的資料量非常大。這些資料不是非常重要，需要定期清理。要求 預設保持24小時，某些topic 需要保留2小時或者6小時 主要有3個 1.基於時間 2.基於日誌大小 3.基於日誌起始偏移量 接下來，主要介紹基於時間的清除！kafka版本為 2.11 1.1.0 zk版本為 3...