學會使用Kafka版本查詢的逐步指南

1. 安裝Kafka

• #在你的伺服器上下載並安裝Apache Kafka。
• 解壓縮Kafka歸檔檔。
• 設定環境變數KAFKA_HOME為Kafka安裝目錄。

2. 啟動ZooKeeper

• #ZooKeeper是Kafka的依賴項，因此在啟動Kafka之前必須先啟動它。
• 開啟命令列終端並導航到$KAFKA_HOME/bin目錄。
• 執行以下命令啟動ZooKeeper：

./zookeeper-server-start.sh config/zookeeper.properties

#3. 啟動Kafka伺服器

• 開啟命令列終端並導航至$KAFKA_HOME/bin目錄。
• 執行下列指令啟動Kafka伺服器：

./kafka-server-start.sh config/server.properties

4. 建立主題

• 主題是Kafka中資料的邏輯分組。
• 要建立主題，請開啟命令列終端並導航到$KAFKA_HOME/bin目錄。
• 執行下列指令建立主題：

./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1

5. 傳送訊息

• 要傳送訊息，請開啟指令行終端機並導航至$KAFKA_HOME/bin目錄。
• 執行以下命令發送訊息：

./kafka-console-producer.sh --topic my-topic --message "Hello, world!"

6. 消費訊息

• 要消費主題的訊息，請開啟命令行終端機並導航至$KAFKA_HOME/bin目錄。
• 執行下列指令消費訊息：

./kafka-console-consumer.sh --topic my-topic --from-beginning

7.查詢版本

• 要查詢Kafka伺服器的版本，請開啟命令列終端機並導航至$KAFKA_HOME/bin目錄。
• 執行以下指令查詢版本：

./kafka-version.sh

範例輸出

kafka-version.sh:
 version: 2.8.0
 kafka-version: 2.8.0
 kafka-storage: 2.8.0
 kafka-clients: 2.8.0
 kafka-streams: 2.8.0
 kafka-connect: 2.8.0
 kafka-admin: 2.8.0
 kafka-tools: 2.8.0

以上是學會使用Kafka版本查詢的逐步指南的詳細內容。更多資訊請關注PHP中文網其他相關文章！