卡夫卡控制台制造商

此工具允许你从命令行生成消息。

将简单的字符串消息发送到主题：

kafka-console-producer --broker-list localhost:9092 --topic test
here is a message
here is another message
^D

（每个新行都是一条新消息，输入 ctrl + D 或 ctrl + C 来停止）

使用密钥发送消息：

kafka-console-producer --broker-list localhost:9092 --topic test-topic \
        --property parse.key=true \
        --property key.separator=,
key 1, message 1
key 2, message 2
null, message 3
^D

从文件发送消息：

kafka-console-producer --broker-list localhost:9092 --topic test_topic < file.log