Kafka控制台生产者不允许写消息

Question

我试图在主题上写一些消息，但是控制台不允许我（生产者不等待stdin输入）。我也看不到任何错误日志。主题已成功创建。我在用 ：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.

Zookeeper和kafka服务器运行正常。我正在使用Mac。可能是什么问题。我正在关注Apache Kafka文档http://kafka.apache.org/documentation.html#quickstart。

Answer 1

行动！同样的问题发生在我的Windows 10，kafka-console-producer.bat文件是空的，现在我要下载新的一个来替换现有的文件。

它替换bat文件后工作。

Answer 2

你好像还没有kafka跑。

sudo jps应该返回这样的东西：

10306 SupportedKafka
17788 Jps

说卡夫卡正在运行。检查你的

log.dirs

配置路径（server.properties）以查看在kafka启动期间是否抛出异常。此外，Kafka建议使用最新的Java（1.8）：http://kafka.apache.org/documentation.html#java

Answer 3

kafka-console-producer.sh文件为空。我遇到了同样的问题。解决方案是用新鲜的替换kafka-console-producer.sh。这可能是仅在Mac OS上发生的问题。

Answer 4

是的，它也发生在我身上，因为文件是空的，所以我复制了将consumer.bat文件信息粘贴到producer.bat并用ConsoleProducer重命名ConsoleConsumer并且它工作正常。

---

@echo off rem根据一个或多个rem贡献者许可协议授权给Apache Software Foundation（ASF）。有关版权所有权的其他信息，请参阅随rem分发的NOTICE文件。 rem ASF根据Apache License，Version 2.0 rem（“许可证”）将此文件许可给您;除非符合许可证，否则您不得使用此文件。您可以在rem rem http://www.apache.org/licenses/LICENSE-2.0 rem rem获取许可证副本除非适用法律要求或书面同意，否则根据许可证分发的软件rem按“原样”分发，不附带任何形式的保证或条件，无论是明示的还是暗示的。 rem有关管理许可下的权限和rem限制的特定语言，请参阅许可证。

SetLocal设置KAFKA_HEAP_OPTS = -Xmx512M“％~dp0kafka-run-class.bat”kafka.tools.ConsoleProducer％* EndLocal