1. 程式人生 > >zookeeper 和 kafka 常用的命令

zookeeper 和 kafka 常用的命令

  • zookeeper 常用的命令

  1.  連線登陸到zookeeper

bin/zkCli.sh -server localhost:2181

此時,輸入“help”可以檢視命令引數:

      2.“ls path”用於檢視路徑path下的所有直接子節點:

     3. create path data”用於在path路徑下建立一個新節點,攜帶資料data。 

例如,在根節點下新建一個名為“myNode”節點,儲存的資料為“HelloWorld”: 

    4. get path 獲取節點下的資料

eg: get /mynode

除了返回節點儲存的資料之外,還有一系列的元資訊,如代表節點建立時間的“cZxid”、“ctime”(兩種表示方法);節點的修改時間“mZxid”、“mtime”等。

   5. set path data 修改資料,

set /mynode dong

   6. delete path 刪除節點

  • kafka 常用的命令

  • Zookeeper 啟動

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

  • kafka啟動

./bin/kafka-server-start.sh config/server.properties

  • 使用 kafka-topics.sh 建立單分割槽單副本的 topic test1:

 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

  • 檢視 topic 列表:

bin/kafka-topics.sh --list --zookeeper localhost:2181

  • 使用 kafka-console-producer.sh 傳送訊息: 

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

  • 使用 kafka-console-consumer.sh 接受訊息: 

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1 --from-beginning

  • 檢視描述 topics 資訊

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test1

同樣一個終端下面,不同的視窗,ctrl+tab 切換