kafka 命令列操作

2021-10-10 05:59:07 字數 1773 閱讀 4209

[


hadoop


@hadoop201


kafka_2.11


-0.11


.0.0]$


bin/


kafka-topics.sh


--list


--zookeeper


hadoop201:


2181
沒有主題時，什麼也不會輸出建立乙個topic，有2個分割槽2個副本

選項說明


--topic 定義topic名


--replication-factor  定義副本數


--partitions  定義分割槽數


[


hadoop


@hadoop201


kafka_2.11


-0.11


.0.0]$


bin/


kafka-topics.sh


--create


--zookeeper


hadoop201:


2181


--topic


mytopic2


--partitions


2--replication-factor


2

[


hadoop


@hadoop201


kafka_2.11


-0.11


.0.0]$


bin/


kafka-topics.sh


--delete


--zookeeper


hadoop201:


2181


--topic


mytopic2
徹底刪除的前提時需要在server.properties中設定delete.topic.enable=true,否則只是標記刪除。

[


hadoop


@hadoop201


kafka_2.11


-0.11


.0.0]$


bin/


kafka-topics.sh


--describe


--topic


mytopic2


--zookeeper


hadoop201:


2181


bin


/kafka-console-producer.sh


--topic


mytopic2


--broker-list


hadoop201:


9092


#從頭消費


bin/


kafka-console-consumer.sh


--topic


mytopic2


--bootstrap-server


hadoop201:


9092


--from-beginning


#從上一次的最大的偏移量處進行消費


bin/


kafka-console-consumer.sh


--topic


mytopic2


--bootstrap-server


hadoop201:


9092

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