我正在使用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
如果我在控制台上写消息,它似乎可以正常工作,但尝试从文件写入失败。所以我猜是因为我在传递信息。
对此有什么见解吗?
1条答案
按热度按时间qni6mghb1#
查看kafkacat,它明确支持从
stdin
,根据文件中给出的示例: