全網最詳細的大數據Kafka文章系列，強烈建議收藏加關注！?

新文章都已經列出歷史文章目錄，幫助大家回顧前面的知識重點。

目錄

系列歷史文章

Kafka的shell命令使用

一、創建topic

二、生產消息到kafka

三、從kafka中消費消息

四、查看主題的命令

五、運行describe的命令

六、?增加topic分區數

七、刪除topic?

八、使用kafka Tools操作Kafka?

---

系列歷史文章

2021年大數據Kafka（十二）：??Kafka配額限速機制??

2021年大數據Kafka（十一）：??Kafka的消費者負載均衡機制和數據積壓問題??

2021年大數據Kafka（十）：kafka生產者數據分發策略

2021年大數據Kafka（九）：kafka消息存儲及查詢機制原理

2021年大數據Kafka（八）：Kafka如何保證數據不丟失

2021年大數據Kafka（七）：Kafka的分片和副本機制

2021年大數據Kafka（六）：??安裝Kafka-Eagle??

2021年大數據Kafka（五）：??Kafka的java API編寫??

2021年大數據Kafka（四）：??kafka的shell命令使用??

2021年大數據Kafka（三）：??Kafka的集群搭建以及shell啟動命令腳本編寫??

2021年大數據Kafka（二）：??Kafka特點總結和架構??

2021年大數據Kafka（一）：??消息隊列和Kafka的基本介紹??

Kafka的shell命令使用

一、創建topic

創建一個topic（主題）。Kafka中所有的消息都是保存在主題中，要生產消息到Kafka，首先必須要有一個確定的主題。

# 創建名為test的主題
bin/kafka-topics.sh --create --bootstrap-server node1:9092 --topic test
# 查看目前Kafka中的主題
bin/kafka-topics.sh --list --bootstrap-server node1:9092

二、生產消息到kafka

使用Kafka內置的測試程序，生產一些消息到Kafka的test主題中。

bin/kafka-console-producer.sh --broker-list node1:9092 --topic test

三、從kafka中消費消息

使用下面的命令來消費 test 主題中的消息。

bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test

四、查看主題的命令

查看kafka當中存在的主題

bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181

五、運行describe的命令

運行describe查看topic的相關詳細信息

bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

六、?增加topic分區數

任意kafka服務器執行以下命令可以增加topic分區數

bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName --partitions 8

七、刪除topic?

目前刪除topic在默認情況下知識打上一個刪除的標記，在重新啟動kafka后才刪除。如果需要立即刪除，則需要 在server.properties中配置：

delete.topic.enable=true

然后執行以下命令進行刪除topic

bin/kafka-topics.sh --zookeeper zkhost:port --delete --topic topicName

八、使用kafka Tools操作Kafka?

1、安裝Kafka Tools后啟動Kafka, 并連接kafka集群

2、安裝Kafka Tools后啟動Kafka, 并連接kafka集群

?

3、使用kafka Tools操作Kafka?

創建topic

查看分區中的數據

---

• 📢博客主頁：https://lansonli.blog.csdn.net
• 📢歡迎點贊 👍 收藏 ?留言 📝 如有錯誤敬請指正！
• 📢本文由 Lansonli 原創，首發于 CSDN博客🙉
• 📢大數據系列文章會每天更新，停下休息的時候不要忘了別人還在奔跑，希望大家抓緊時間學習，全力奔赴更美好的生活?

總結

以上是生活随笔為你收集整理的2021年大数据Kafka（四）：❤️kafka的shell命令使用❤️的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。