kafka極簡入門(三)--建立topic

回顧kafka極簡入門(二)--安裝

topic是kafka的生產者和消費者最小交互的單位，咱們先從topic入手，建立第一個topic.

• 進去kafka的bin目錄咱們發現有個kafka-topics.sh腳本

1.建立topic

• 官方推薦若是kafka版本大於等於2.2使用--bootstrap-server替代--zookeeper （2.2以上也兼容--zookeeper）命令以下

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytest

• 若是kafka版本小於2.2則命令以下

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest

參數解釋

• 1.指定kafka集羣(2.2以上)或zookeeper集羣

--bootstrap-server node1:9092,node2:9092,node3:9092....

或

--zookeeper node1:2181,node2:2181,node3:2181...

• 2.指定分區數

--partitions

• 3.指定分區的副本數

--replication-factor

因此執行上面命令將會建立一個名爲mytest的topic，該topic下面有1個分區,而且該分區只有1個副本。

PS:除了手動建立主題外，還能夠將代理配置爲在發佈不存在的主題時自動建立主題

2.查看topic

• 查看指定的topic

kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic mytest

Partition:0 表示該分區的id爲0
leader: 9 表示分區的首領副本所在的broker（本例子中broker.id配置爲9,因此這裏顯示9,具體在config/server.properties配置。這裏只有一個分區，因此首領分區也就是本身）
Replicas: 9 表示分區的跟隨副本所在的broker
Isr: 9 表示分區的同步副本所在的broker(同步副本能夠認爲跟首領副本準實時同步的副本，能夠配置判斷條件，後面會講，首領副本掛掉後，服務器會從同步副本中選舉新的首領)

• 查看全部可用的topic

kafka-topics.sh --list--bootstrap-server localhost:9092

3.測試

• 3.1 往topic發佈信息

kafka-console-producer.sh --broker-list localhost:9092 --topic mytest

發送三個消息，分別是hello, world和！

• 3.2 消費消息

新開一個控制檯

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

注意: --from-beginning 表示從最開始的offset處開始消費。若是不寫表示從最新的offset處消費，那麼先發送了消息再開啓消費者是收不到已發送的信息的

接收成功。

kafka極簡入門(四)--經常使用配置

若是對你有用麻煩點個贊哦 ^_^