kafka常用操作命令

**(broker)：kafka集群由乙個或多個伺服器組成。每個伺服器稱為**

主題(topic)：維護一組訊息分類

分割槽(partition)：隸屬於主題，每個主題會包含多個分割槽，

訊息(msg)：隸屬於分割槽，每個分割槽有乙個訊息序列，每個訊息在該分割槽中都有乙個唯一的序號，這個序號叫偏移量

生產者(producer)：向kafka傳送訊息

消費者(consumer)：訂閱並消費主題中的訊息

描述：kafka作為訊息佇列，將訊息作為檔案存放於介質上，邏輯劃分從大到小為：kafka集群—kafka**—主題—分割槽—訊息。他們都是一對多關係二叉樹結構

基於windows ，下列所有命令都以kafka自帶工具，目錄為：f:\lb\soft\kafka\bin\windows

1、  檢視現有topic(主題)列表

kafka-topics.bat --list --zookeeper localhost:2181

2、  建立topic(主題)

kafka-topics.bat--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictest

其中test為主題名稱

3、  啟動producer(生產者)

kafka-console-producer.bat --broker-listlocalhost:9092 --topic test

**為本地9092程序，主題為test繫結乙個producer

4、  啟動consumer(消費者)

kafka-console-consumer.bat–zookeeperlocalhost:2181 –topic test –from-beginning

zk為2181，主題為test

5、   

6、   

Kafka常用操作命令

建立主題 kafka topics create bootstrap server node01 9092 replication factor 3 partitions 3 topic test檢視主題列表 kafka topics list bootstrap server node01 909...

kafka 常用操作命令

1 建立topic 訊息佇列 kafka topics.sh create zookeeper 192.168.116 2181 你的zookeeper的ip topic mydemo 訊息佇列的名稱 replication factor 1 副本數 partitions 1 分割槽數2 檢查佇列是...

七 kafka常用操作命令

nohup bin kafka server start.sh config server.properties 檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper node1 2181 建立topic bin kafka topics.sh cr...