Kafka常用命令

1. 建立topic

# 注意：一般在系統設計的時候，先把topic規劃好，業務含義相同的資料，放在乙個topic中。
[root@kafka1 kafka]# bin/kafka-topics.sh --zookeeper kafka1:2181 --create --topic topica --partitions 3 --replication-factor 2
## ---------------引數說明------------------ ##
--zookeeper 連線的zookeeper
--create 表示要建立乙個topic
--topic 指定topic的名字(不同業務的資料，放在不同的topic中)
--partitions 指定分割槽數
--replication-factor 指定副本數
2. 檢視所有topic
[root@kafka1 kafka]# bin/kafka-topics.sh --zookeeper kafka1:2181 --list
3. 檢視某個topic詳情
4. 刪除topic

[root@kafka1 kafka]# bin/kafka-topics.sh --zookeeper kafka1:2181 --delete --topic topica
5. 接收訊息
[root@kafka1 kafka]# bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic topica
6. 傳送訊息
[root@kafka1 kafka]# bin/kafka-console-producer.sh --broker-list kafka1:9092 --topic topica
7. 啟動集群
bin/kafka-server-start.sh -daemon config/server.properties
8. 關閉集群
bin/kafka-server-stop.sh
 
kafka常用命令
kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...
kafka常用命令
啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...
Kafka 常用命令
kafka console producer broker list 127.0.0.1 9092 topic mytopic kafka console consumer bootstrap server 127.0.0.1 9092 topic mytopic 建立主題,replication ...