kafka常用的shell命令
- 1、創建topic
- 2、查看創建的topic
- 3、生產者發布訊息命令
- 4、消費者接受訊息命令
- 5、kafka啟動
- 6、查看kafka節點數目
- 7、kafka中的概念
- 8、查看主題資訊
- 9、為主題創建磁區
- 10、查看kafka行程
- 11、kafka宕機重啟后，訊息不會丟失
- 12、kafka其中一個broker宕機后，對消費者和生產者影響很小（命令列下測驗）
kafka系列
Kafka史上最詳細原理總結(一)
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、kafka中的概念
生產者 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 test
9、為主題創建磁區
bin/kafka-topics.sh --zookeeper 192.168.91.231:2181 --alter -partitions 8 -topic test
一共創建八個磁區，編號分別為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.uj5u.com/qita/294892.html
標籤：其他
下一篇：關于大資料下資料一致性的思考