Kafka 控制台生产者什么也没返回

问题描述 投票:0回答:2

嗨,我正在经历快速启动,当我输入

bin/kafka-console-producer.sh --broker-list localhost:9093 --topic first

时,我遇到了错误

当我期待文本输入将消息发送给 Kafka 生产者时,我什么也没得到。我已按照单个和多个经纪商设置的说明进行操作,但似乎没有任何效果。我的 Zookeeper 正在运行,我看到在正确的日志目录中创建的日志文件,但没有任何关于我的消息的信息。

我也尝试过像这样管道它

cat test.txt | bin/kafka-console-producer.sh --broker-list localhost:9093 --topic first
echo test message | bin/kafka-console-producer.sh --broker-list localhost:9093 --topic first

还有其他我应该检查的问题吗?

apache-kafka kafka-producer-api
2个回答
4
投票

同样的事情也发生在我身上。令人惊讶的是 bin\windows\kafka-console- Producer.bat 文件的大小为 0。只需替换为原始文件即可工作。


0
投票

当我们像这样运行任何 kafka 批处理文件时,文件大小将变为 0。 C:\kafka in\windows>>kafka-topics.bat --create --bootstrap-server localhost:9092 --topic 主题名称。

这里我们错误地给出了两次 (>>) 运算符,而不是单个 (>) 运算符。 >> 操作员将特定文件大小设为 0。

这就是为什么用原始文件替换该文件是有效的。

© www.soinside.com 2019 - 2024. All rights reserved.