[sea@hadoop002 kafka]$bin/kafka-topics.sh --zookeeperhost12:2181 --list
[sea@hadoop002 kafka]$bin/kafka-topics.sh --zookeeperhost12:2181 --create --replication-factor 3 --partitions 1 --topiclrxtest0625
選項說明：
--topic 定義topic名
--replication-factor 定義副本數
--partitions 定義分割槽數
[sea@hadoop002 kafka]$bin/kafka-topics.sh --zookeeperhost12:2181 --delete --topiclrxtest0625
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。
[sea@hadoop002 kafka]$bin/kafka-console-producer.sh --broker-listhost12:9092 --topiclrxtest0625
>hello world
>sea sea
[sea@hadoop103 kafka]$bin/kafka-console-consumer.sh --bootstrap-server host12:9092 --from-beginning --topic lrxtest0625
--from-beginning：會把first主題中以往所有的資料都讀取出來。根據業務場景選擇是否增加該配置。
--bootstrap-server：生產訊息的伺服器
[sea@hadoop002 kafka]$bin/kafka-topics.sh --zookeeperhost12:2181 --describe --topiclrxtest0625
（如果是cdh中安裝的kafka，則直接執行命令即可，cdh已經將命令設為全域性作用域了）即：
[sea@hadoop002 kafka]$kafka-topics --zookeeperhost12:2181 --list
如果cdh中設定了路徑，則上述命令要加路徑：
選項說明：
--topic 定義topic名
--replication-factor 定義副本數
--partitions 定義分割槽數
[sea@hadoop002 kafka]$kafka-topics --zookeeperhost12:2181/data2/kafka--delete --topiclrxtest0625
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。
[sea@hadoop002 kafka]$kafka-console-producer --broker-listhost12:9092 --topiclrxtest0625
>hello world
>sea sea
[sea@hadoop103 kafka]$kafka-console-consumer --bootstrap-server host12:9092 --from-beginning --topic lrxtest0625
--from-beginning：會把first主題中以往所有的資料都讀取出來。根據業務場景選擇是否增加該配置。
--bootstrap-server：生產訊息的伺服器
Kafka命令列操作
1 檢視當前伺服器中的所有topic atguigu hadoop102 kafka bin kafka topics.sh zookeeper hadoop102 2181 list2 建立topic atguigu hadoop102 kafka bin kafka topics.sh zook...
Kafka 命令列操作
1.檢視當前伺服器中的所有 topic bin kafka topics.sh zookeeper localhost 2181 list2.建立 topic bin kafka topics.sh zookeeper localhost 2181 create replication factor...
Kafka命令列操作
1.檢視當前伺服器中的所有topicbin kafka topics.sh zookeeper bigdata13 2181 list2.建立topicbin kafka topics.sh zookeeper bigdata13 2181 create replication factor 3 p...