Kafka Tool 是一個用于與 Apache Kafka 進行交互的命令行工具。要使用 Kafka Tool 發送消息,請按照以下步驟操作:
打開命令行終端(如 Windows 的 cmd 或 PowerShell,macOS 和 Linux 的 Terminal)。
使用 cd
命令導航到 Kafka Tool 的安裝目錄。例如,如果 Kafka Tool 安裝在 /usr/local/kafka-tool
,則輸入 cd /usr/local/kafka-tool
。
確保 Kafka 服務正在運行。你可以通過運行以下命令檢查 Kafka 服務的狀態:
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
使用 kafka-console-producer.sh
腳本來發送消息。你需要指定 Kafka 代理的地址和主題名稱。例如,要將消息發送到名為 my-topic
的主題,你可以運行以下命令:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
在打開的命令行提示符中,輸入要發送的消息,然后按 Enter 鍵。消息將被發送到指定的 Kafka 主題。
注意:在實際生產環境中,你需要將 --broker-list
參數替換為實際的 Kafka 代理地址,將 --topic
參數替換為實際的主題名稱。