Kafka常用命令

kafka的bin目錄下有許多指令碼，方便使用，例如與主題相關的kafka-topics.sh 指令碼，這裡假設kafka在zookeeper上的根目錄為/kafka1

1.檢視主題：

sh kafka-topics.sh --list --zookeeper zk_ip1:2181,zk_ip2:2181,zk_ip3:2181/kafka1

2.建立主題：

sh kafka-topic.sh --create --partitions 2 --replication-factor 2 --zookeeper zk_ip:2181/kafka1  --topic customer //建立主題customer,含有兩個分割槽，分割槽副本數為2

3.刪除主題：

sh kafka-topics.sh --zookeeper zk_ip1:2181,zk_ip2:2181,zk_ip3:2181/kafka1 --delete --topic customer

sh zookeeper-shell.sh zk_ip:2181ls /kafka1

get /kafka1/brokers/ids/2

5. 控制台列印主題中的訊息

sh kafka-console-consumer.sh --zookeeper ip1:2181,ip2:2181,ip3:2181/kafka1 --topic demo1 --from-beginning

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 ...