kafka相關命令

1.群起指令碼 

#!/bin/bash

case $1 in 
"start");;
"stop");;
esac

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

3.建立主題

kafka-topics.sh --create --zookeeper k8smaster --topic first --partitions 3 --replication-factor 1

4.刪除主題

./kafka-topics.sh --delete -zookeeper k8smaster:2181 --topic first

5.檢視主題

kafka-topics.sh --describe topics first --zookeeper k8smaster

6.控制台測試訊息生產

kafka-console-producer.sh --topic first --broker-list k8smaster:9092

7.控制台測試訊息消費

kafka-console-consumer.sh --topic first --bootstrap-server k8smaster:9092 --from-beginning

8.啟動zk

sh /opt/software/zookeeper-3.4.14/bin/zkserver.sh start

jps

kafka 客戶端工具：kafka tool

kafka集群的broker，主題，分割槽，副本。消費者等的展示。可以通過工具建立主題 

kafka相關命令整理

1 啟動kafka zookeeper服務命令 nohup bin zookeeper server start.sh config zookeeper.properties dev null 2 1 2 啟動kafka broker服務命令 nohup bin kafka server start...

kafka相關操作命令

1 開啟zookeeper集群 startzk.sh 2 開啟kafka集群 start kafka.sh 3 開啟kafka視覺化介面 kafka manager start kafka manager.sh 4 生產者操作 kafka console producer.sh broker lis...

kafka相關命令操作

啟動kafka 到每個節點啟動 node01 nohup bin kafka server start.sh config server.properties node02 nohup bin kafka server start.sh config server.properties node03...