kafka常用shell命令： ------------------------------------

1、創建topic

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

2、查看創建的topic

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

3、生產者發布消息命令（執行完此命令后，在控制臺輸入要發送的消息，回車即可）

　　bin/kafka-console-producer.sh --broker-list 192.168.91.231:9092,192.168.91.231:9093,192.168.91.231:9094 --topic test

4、消費者接受消息命令

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

5、kafka啟動 ???

　　首先啟動zookeeper zkServer.sh start（相當于一個server,kafka會連接這個server） ??? 啟動kafka bin/kafka-server-start.sh config/server.properties ???

6、查看kafka節點數目 ???

　　在zookeeper中查看，登錄客戶端bin/zkCli.sh ??? 執行ls /brokers/ids 查看節點數目及節點ID，[0, 1, 2]

7、kafuka中的概念 ???

　　生產者Producer、代理Broker、消費者Consumer、主題Topic、分區Partition、消費者組Consumer Group

8、查看主題信息 ???

　　bin/kafka-topics.sh --zookeeper 192.168.91.231:2181 [加其他選項]??? ?

　　eg:bin/kafka-topics.sh --zookeeper 192.168.91.231:2181 --describe ???

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

9、為主題創建分區 ???

　　bin/kafka-topics.sh --zookeeper 192.168.91.231:2181 --alter -partitions 8 -topic panteng ???

　　一共創建八個分區，編號分別為0~7

10、查看kafka進程 ???

　　ps -ef|grep server.properties ??? ps -ef|grep server-1.properties ??? ps -ef|grep server-2.properties

11、kafka宕機重啟后，消息不會丟失

12、kafka其中一個broker宕機后，對消費者和生產者影響很小（命令行下測試） ???

　　 消費者會嘗試連接，連接不到，返回java.net.ConnectException: Connection refused異常 ??? 生產者可能會在發送消息的時候報異常，但會很快連接到其他broker，繼續正常使用

轉載于:https://www.cnblogs.com/tengpan-cn/p/5890219.html

總結

以上是生活随笔為你收集整理的kafka常用的shell命令的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。