安裝/下載、解壓
-
使用版本：Scala 2.13 - kafka_2.13-3.1.0.tgz
-
官網下載：https://kafka.apache.org/downloads
解壓到一個目錄即可，也可用brew，
下面bash都在根目錄執行
啟動
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
topic
創建topic，3.0版本已不依賴zk
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic Hello-Kafka
Created topic Hello-Kafka.
生產訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka
消費訊息
新開一個終端
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Hello-Kafka --from-beginning
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/433338.html
標籤：其他