嗨,我正在经历快速启动,当我输入
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
还有其他我应该检查的问题吗?
同样的事情也发生在我身上。令人惊讶的是 bin\windows\kafka-console- Producer.bat 文件的大小为 0。只需替换为原始文件即可工作。
当我们像这样运行任何 kafka 批处理文件时,文件大小将变为 0。 C:\kafka in\windows>>kafka-topics.bat --create --bootstrap-server localhost:9092 --topic 主题名称。
这里我们错误地给出了两次 (>>) 运算符,而不是单个 (>) 运算符。 >> 操作员将特定文件大小设为 0。
这就是为什么用原始文件替换该文件是有效的。