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

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

目錄

系列歷史文章

Kafka的shell命令使用

一、創(chuàng)建topic

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

三、從kafka中消費(fèi)消息

四、查看主題的命令

五、運(yùn)行describe的命令

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

七、刪除topic?

八、使用kafka Tools操作Kafka?

---

系列歷史文章

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

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

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

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

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

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

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啟動(dòng)命令腳本編寫??

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

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

Kafka的shell命令使用

一、創(chuàng)建topic

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

# 創(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中消費(fèi)消息

使用下面的命令來消費(fèi) test 主題中的消息。

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

四、查看主題的命令

查看kafka當(dāng)中存在的主題

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

五、運(yùn)行describe的命令

運(yùn)行describe查看topic的相關(guān)詳細(xì)信息

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在默認(rèn)情況下知識(shí)打上一個(gè)刪除的標(biāo)記，在重新啟動(dòng)kafka后才刪除。如果需要立即刪除，則需要 在server.properties中配置：

delete.topic.enable=true

然后執(zhí)行以下命令進(jìn)行刪除topic

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

八、使用kafka Tools操作Kafka?

1、安裝Kafka Tools后啟動(dòng)Kafka, 并連接kafka集群

2、安裝Kafka Tools后啟動(dòng)Kafka, 并連接kafka集群

?

3、使用kafka Tools操作Kafka?

創(chuàng)建topic

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

---

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

總結(jié)

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

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