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 中,命令和选项可能有所不同。