全網(wǎng)最詳細的大數(shù)據(jù)Kafka文章系列，強烈建議收藏加關(guān)注！?

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

目錄

系列歷史文章

Kafka的shell命令使用

一、創(chuàng)建topic

二、生產(chǎn)消息到kafka

三、從kafka中消費消息

四、查看主題的命令

五、運行describe的命令

六、?增加topic分區(qū)數(shù)

七、刪除topic?

八、使用kafka Tools操作Kafka?

---

系列歷史文章

2021年大數(shù)據(jù)Kafka（十二）：??Kafka配額限速機制??

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

2021年大數(shù)據(jù)Kafka（十）：kafka生產(chǎn)者數(shù)據(jù)分發(fā)策略

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

2021年大數(shù)據(jù)Kafka（八）：Kafka如何保證數(shù)據(jù)不丟失

2021年大數(shù)據(jù)Kafka（七）：Kafka的分片和副本機制

2021年大數(shù)據(jù)Kafka（六）：??安裝Kafka-Eagle??

2021年大數(shù)據(jù)Kafka（五）：??Kafka的java API編寫??

2021年大數(shù)據(jù)Kafka（四）：??kafka的shell命令使用??

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

2021年大數(shù)據(jù)Kafka（二）：??Kafka特點總結(jié)和架構(gòu)??

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

Kafka的shell命令使用

一、創(chuàng)建topic

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

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

二、生產(chǎn)消息到kafka

使用Kafka內(nèi)置的測試程序，生產(chǎn)一些消息到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的相關(guān)詳細信息

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

六、?增加topic分區(qū)數(shù)

任意kafka服務(wù)器執(zhí)行以下命令可以增加topic分區(qū)數(shù)

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

七、刪除topic?

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

delete.topic.enable=true

然后執(zhí)行以下命令進行刪除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?

創(chuàng)建topic

查看分區(qū)中的數(shù)據(jù)

---

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。