1. 程式人生 > >kafka命令操作

kafka命令操作

官網上是沒有提供直接windows版本的topic處理程式的,執行命令之前加kafka-run-class.bat kafka.admin.TopicCommand %*
或者自己新建一個bat檔案。
1、建立Topic

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic my-replicated-topic 

kafka-topics.bat:裡面就是kafka-run-class.bat kafka.admin.TopicCommand %* 命令
replication-factor:表示該topic需要在不同的broker中儲存
partitions : 對該top的分割槽數量
topic : 該top的名稱。建議指定。否則採用預設

2、檢視topic

kafka-topics.bat --describe --zookeeper localhost:2181 --topic my-replicated-topic

3、生產訊息

kafka-console-producer.bat --broker-list localhost:9093 --topic my-replicated-topic

4、消費訊息

kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic my-replicated-topic

關於生產和消費可以通過程式碼實現,可以根據API文件來寫,網上例子也很多,可參考

5、檢視log檔案

bin/kafka-run-class.bat kafka.tools.DumpLogSegments --files /tmp/kafka-logs/test3-0/00000000000000000000.log  --print-data-log