kafka控制台生产者从文件读取失败

kognpnkq  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(499)

我正在使用Kafka11并试图从一个文件中写入一个主题。
我正在使用下面的命令

kafka-console-producer --broker-list my-bootstrap-url:9092 --topic my.test.messages < my_file.txt

它又回来了

ERROR Error when sending message to topic my.test.messages with key: 
null, value: 2376 bytes with error: 
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Batch containing 22 
record(s) expired due to timeout while requesting metadata from brokers 
for my.test.messages-0

如果我在控制台上写消息,它似乎可以正常工作,但尝试从文件写入失败。所以我猜是因为我在传递信息。
对此有什么见解吗?

qni6mghb

qni6mghb1#

查看kafkacat,它明确支持从 stdin ,根据文件中给出的示例:

$ tail -f /var/log/syslog | kafkacat -b mybroker -t syslog -z snappy

相关问题