kafka中文教程 學習記錄
首先準備好linux機器環境，參考此篇文章：快速搭建Linux服務器環境
單機版
1. 下載代碼
https://kafka.apache.org/downloads.html
官方的下載鏈接比較慢，這里可以使用第三方下載轉發的鏈接地址：
wget --no-check-certificate https://dl0.serctl.com/downloads8/2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ ll
total 84372
-rw-rw-r--. 1 vagrant vagrant 86396520 Sep 20 08:46 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ tar -xzf 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ cd kafka_2.13-3.0.0/
2. 啟動服務
啟動kafka 需要jdk環境，可參考這篇文章：在linux上面安裝jdk
kafka自帶打包和配置好的Zookeeper
啟動Apache Kafka 內置的zookeeper
$ cd kafka_2.13-3.0.0/
$ bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka服務
$ cd kafka_2.13-3.0.0/
$ bin/kafka-server-start.sh config/server.properties
3. 創建一個主題(topic)
創建一個名為“test”的Topic，只有一個磁區和一個備份
$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
查看已創建的topic資訊：
$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092
Topic: test TopicId: DdW4QskuTH2DwnGvM0Mjdg PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824
Topic: test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
4. 發送訊息
生產者
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message
5. 消費訊息
$ cd kafka_2.13-3.0.0/
$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
上面我們使用命令的方式簡單演示了一下kafka的基本流程，
你有哪些疑問嗎？
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/352146.html
標籤：其他