zookeeper 和 kafka 常用的命令
-
zookeeper 常用的命令
- 連線登陸到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 切換