Kafka基本操作該怎么執(zhí)行

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

Topic 主題

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

創(chuàng)建topic

自動創(chuàng)建

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

手動創(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)容，你們對Kafka基本操作該怎么執(zhí)行有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。