今天就跟大家聊聊有關(guān)Kafka基本操作該怎么執(zhí)行，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)！專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、微信小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了翔安免費(fèi)建站歡迎大家使用！

Topic 主題

當(dāng)kafka數(shù)據(jù)進(jìn)行持久化的時(shí)，為了區(qū)分不同的業(yè)務(wù)主題，設(shè)計(jì)了主題這個(gè)概念，類似數(shù)據(jù)庫會(huì)有數(shù)據(jù)庫名，數(shù)據(jù)庫有若干數(shù)據(jù)表。不同類型消息數(shù)據(jù)按一定的規(guī)則進(jìn)行分類，最后相同類型業(yè)務(wù)數(shù)據(jù)存儲(chǔ)到同一個(gè)主題下。

創(chuàng)建topic

自動(dòng)創(chuàng)建

通過auto.create.topocs.enable屬性來自動(dòng)創(chuàng)建主題，默認(rèn)該值是true。當(dāng)生產(chǎn)者項(xiàng)kafk發(fā)送一個(gè)不存在的主題的時(shí)候，kafka會(huì)創(chuàng)建一個(gè)默認(rèn)配置系數(shù)的主題。其中默認(rèn)分區(qū)的數(shù)值由num.partitions控制，默認(rèn)副本系數(shù)由default.replication.factor控制。具體配置文件在當(dāng)前kafka的config/server.properties

手動(dòng)創(chuàng)建

具體命令如下，主題名是topic-test，由于是開發(fā)環(huán)境搭建 分區(qū)和副本分區(qū)都是1

$ kafka-topics.sh --zookeeper localhost: 2181/kafka --create --topic topic-test --replication-factor 1 --partitions 1Created topic "topic-test".

--topic 定義topic名

--replication-factor  定義副本數(shù)

--partitions  定義分區(qū)數(shù)

查看topic

查看所有的topic

 $kafka-topics.sh --list -zookeeper localhost:2181__consumer_offsetstopic-test

查看topic 詳情

$ kafka-topics.sh --zookeeper localhost:2181 --describe --topic topic-testTopic:test  PartitionCount:1  ReplicationFactor:1 Configs:  Topic: test Partition: 0  Leader: 0 Replicas: 0 Isr: 0

發(fā)送/接收消息

$ kafka-console-producer.sh --broker-list localhost:9092 --topic topic-test>hello kafka>hello world

kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic topic-testhello world

看完上述內(nèi)容，你們對(duì)Kafka基本操作該怎么執(zhí)行有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。