我试图写一些关于主题的消息，但控制台不允许我（生产者不等待标准输入）。我也看不到任何错误日志。主题已成功创建。我正在使用：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.zookeeper和kafka服务器运行良好。我在用mac。可能的问题是什么。我正在关注apachekafka文档http://kafka.apache.org/documentation.html#quickstart.
我试图写一些关于主题的消息，但控制台不允许我（生产者不等待标准输入）。我也看不到任何错误日志。主题已成功创建。我正在使用：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.zookeeper和kafka服务器运行良好。我在用mac。可能的问题是什么。我正在关注apachekafka文档http://kafka.apache.org/documentation.html#quickstart.
4条答案
按热度按时间ohfgkhjo1#
kafka-console-producer.sh文件为空。我也面临同样的问题。解决办法是kafka-console-producer.sh用一个新的。这可能是一个只在macos上发生的问题。6ss1mwsb2#
行动！同样的问题也发生在我的Windows10上，kafka-console-producer.bat文件是空的，现在我要下载一个新的文件来替换现有的文件。
它在替换bat文件后工作。
8gsdolmq3#
你似乎还没有让Kafka参选。
sudo jps应该返回如下内容：
说Kafka在跑。检查您的
配置路径（server.properties）以查看在kafka启动期间是否引发异常。Kafka还建议使用最新的java（1.8）：http://kafka.apache.org/documentation.html#java
kuuvgm7e4#
是的，这也发生在我身上，因为文件是空的，所以我复制粘贴了consumer.bat文件信息到producer.bat中，并用consoleproducer重命名consoleconsumer，结果成功了。
在一个或多个REM贡献者许可协议下，向Apache软件基金会（ASF）发出回响REM。有关版权所有权的更多信息，请参阅随本作品一起分发的通知文件。rem asf根据apache许可证2.0 rem版本（以下简称“许可证”）将此文件许可给您；除非符合许可证的要求，否则您不能使用此文件。您可以在rem处获得许可证副本http://www.apache.org/licenses/license-2.0 rem rem除非适用法律要求或书面同意，否则根据许可证分发的软件rem是按“原样”分发的，rem没有任何明示或暗示的保证或条件。rem请参阅许可证，以了解管理许可证下的权限和rem限制的特定语言。
setlocal set kafka \u heap \u opts=-xmx512m“%~dp0kafka run class.bat”kafka.tools.consoleproducer%*endlocal