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
参数替换为实际的主题名称。