Kafka Tool 是一個用于與 Apache Kafka 進行交互的命令行工具。要使用 Kafka Tool 發送消息,你需要首先確保已經正確安裝并配置了 Kafka 和 Kafka Tool。接下來,你可以通過以下步驟配置參數并發送消息:
打開命令行終端(如 Windows 的 cmd 或 PowerShell,macOS 和 Linux 的 Terminal)。
使用 kafka-console-producer.sh(Linux 和 macOS)或 kafka-console-producer.bat(Windows)腳本啟動 Kafka Tool。這將啟動一個生產者客戶端,連接到指定的 Kafka 主題。
例如,要連接到名為 my-topic 的主題,你可以在命令行中輸入以下命令:
./kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
在 Windows 上,命令如下:
kafka-console-producer.bat --broker-list localhost:9092 --topic my-topic
在命令行終端中輸入消息并按 Enter 鍵發送。消息將被發送到指定的 Kafka 主題。
若要配置其他參數,可以使用 --property 選項。例如,要設置消息的鍵和值的序列化類型,可以使用以下命令:
./kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic --property key.serializer=org.apache.kafka.common.serialization.StringSerializer --property value.serializer=org.apache.kafka.common.serialization.StringSerializer
在 Windows 上,命令如下:
kafka-console-producer.bat --broker-list localhost:9092 --topic my-topic --property key.serializer=org.apache.kafka.common.serialization.StringSerializer --property value.serializer=org.apache.kafka.common.serialization.StringSerializer
這將設置鍵和值的序列化類型為字符串。你可以根據需要更改這些參數值。更多關于 Kafka Tool 的配置選項,可以參考官方文檔:https://kafka.apache.org/documentation/#console_producer
請注意,這些步驟適用于 Kafka Tool 0.11.0.0 及更高版本。在早期版本的 Kafka Tool 中,命令和選項可能有所不同。