參考百度文章,搭建KAFKA本地集羣。windows
這裏要注意一個坑:url
kafka的config/server.properties文件中的broker.id要和kafka-logs/meta.properties裏面的broker.id一致,而kafka-logs/meta.properties是在第一次運行kafka以後生成的。若是不一致,咱們能夠修改成一致,再啓動kafka,若是咱們部署kafka集羣,是複製粘貼多個kafka文件夾出來的,那就記得必定要改。spa
啓動
.\bin\windows\kafka-server-start.bat .\config\server.propertiesserver
建立主題
cmd進入 bin/windows文件夾:運行命令
kafka-topics.bat --create --zookeeper 127.0.0.1:2180,127.0.0.1:2181,127.0.0.1:2182 --replication-factor 2 --partitions 2 --topic mytopic
指令說明:
–create 指定建立topic動做
--zookeeper 指定kafka鏈接zk的鏈接url,該值和server.properties文件中的配置項{zookeeper.connect}同樣
–replication-factor:指定每一個分區的複製因子個數,默認1個
–partitions:指定當前建立的kafka分區數量,默認爲1個
–topic:設置主題名字
2.查看主題狀態
cmd進入 bin/windows文件夾:運行命令 blog
kafka-topics.bat --describe --zookeeper 127.0.0.1:2180,127.0.0.1:2181,127.0.0.1:2182 --topic mytopic 部署
結果信息字段含義:
1 Partition: 分區
2 Leader : 負責讀寫指定分區的節點
3 Replicas : 複製該分區log的節點列表
4 Isr : 「in-sync」 replicas,當前活躍的副本列表(是一個子集),而且可能成爲Leader
kafka