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

【问题标题】：Kafka console producer not allowing to write messageKafka 控制台生产者不允许写入消息
【发布时间】：2016-11-13 15:10:30
【问题描述】：

我正在尝试写一些关于主题的消息，但控制台不允许我（生产者不等待标准输入）。我也看不到任何错误日志。虽然主题创建成功。我正在使用：

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

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

【问题讨论】：

您使用的是哪个版本的 kafka？另外，尝试在您的终端上执行 sudo jps 并告知您所看到的内容。
Kafka 版本是 0.10.0.0 和 2.11 scala 版本 (kafka_2.11-0.10.0.0) 。除了 jps 本身之外，sudo jps 没有任何结果。

标签： apache-kafka kafka-producer-api

【解决方案1】：

操作！我的 windows 10 也出现了同样的问题，kafka-console-producer.bat 文件是空的，现在我要下载一个新的来替换现有文件。

替换bat文件后即可使用。

【讨论】：

【解决方案2】：

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

【讨论】：

【解决方案3】：

您似乎还没有运行 kafka。

sudo jps 应该返回如下内容：

10306 SupportedKafka
17788 Jps

说 kafka 正在运行。检查你的

log.dirs

config path (server.properties) 查看kafka启动时是否抛出异常。另外，Kafka 推荐使用最新的 Java (1.8)：http://kafka.apache.org/documentation.html#java

【讨论】：

Jps 命令显示：14049 Kafka。 Kafka 服务器正在运行。我不确定 sudo jps 会做什么。我能够使用 Java 类生成和使用消息。只有控制台有问题。日志也没有任何错误。 Java 版本也是 1.8。
jps 是一个 jvm 进程状态工具 (docs.oracle.com/javase/7/docs/technotes/tools/share/jps.html) 。我不知道 .sh 是否在您的情况下引起问题。当我以 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test3 运行命令时，它对我来说也失败了。尝试不使用 .sh (bin/kafka-console-producer --broker-list localhost:9092 --topic test3)
它发送错误-bash: bin/kafka-console-producer: No such file or directory
问题已解决，我刚刚注意到 kafka-console-producer.sh 文件为空。我得到了 kafka 的新副本并复制了文件的内容。感谢您的帮助@sharath。
酷！比较软件下载的 md5 哈希值始终是一个好习惯 :)

【解决方案4】：

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

@echo 关闭 rem 获得 Apache Software Foundation (ASF) 的一项或多项许可 rem 贡献者许可协议。请参阅分发的 NOTICE 文件 rem 这项工作以获取有关版权所有权的更多信息。 rem ASF 根据 Apache 许可证 2.0 版将此文件许可给您 rem（“许可证”）；除非符合以下规定，否则您不得使用此文件 rem 许可证。您可以在以下网址获取许可证的副本雷姆雷姆http://www.apache.org/licenses/LICENSE-2.0 雷姆 rem 除非适用法律要求或书面同意，否则软件根据许可分发的 rem 按“原样”分发， rem 不提供任何明示或暗示的保证或条件。 rem 请参阅许可证以获取特定语言的管理权限和许可证下的 rem 限制。

设置本地设置 KAFKA_HEAP_OPTS=-Xmx512M "%~dp0kafka-run-class.bat" kafka.tools.ConsoleProducer %* 结束本地

【讨论】：