Kafka基本操作該怎么執行

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

Topic 主題

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

創建topic

自動創建

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

手動創建

具體命令如下，主題名是topic-test，由于是開發環境搭建 分區和副本分區都是1

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

--topic 定義topic名

--replication-factor  定義副本數

--partitions  定義分區數

查看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

發送/接收消息

$ 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

看完上述內容，你們對Kafka基本操作該怎么執行有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。