当前位置: 首页 > 知识库问答 >
问题:

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

杨豪
2023-03-14

我试着写一些关于主题的消息,但是控制台不允许(生产者不等待标准输入)。我也看不到任何错误日志。尽管主题已成功创建。我正在使用:

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

动物园管理员和Kafka服务器运行良好。我使用的是苹果电脑。可能的问题是什么。我正在关注阿帕奇Kafka文档 http://kafka.apache.org/documentation.html#quickstart。

共有3个答案

闻人锦
2023-03-14

你似乎还没有Kafka在运行。

sudo jps应该返回如下内容:

10306 SupportedKafka
17788 Jps

说Kafka在跑步。检查您的

log.dirs

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

傅旺
2023-03-14

< code > Kafka-console-producer . sh 文件为空。我也面临同样的问题。解决方法是用一个新的替换< code > Kafka-console-producer . sh 。这可能是仅在Mac OS上发生的问题。

秦飞航
2023-03-14

老年 退休金 计划!同样的问题发生在我的Windows 10上,kafka控制台生产者.bat文件是空的,现在我要下载一个新的来替换现有的文件。

它在替换bat文件后工作。

 类似资料:
  • 我有一个需要使用Kafka Console Producer发送键值消息的用例。那么如何通过命令实现这一点呢?

  • 我需要更改Kafka设置中的值序列化器/反序列化器(出于测试目的,我一直在使用IntegerSerializer/IntegerDeserializer)。使用javaapi,它完全按照预期工作;但是,当使用控制台工具时,它似乎无法正常工作。 我所做的所有故障排除都让我得出了一个结论:Kafka控制台制作人似乎忽略了序列化程序选项。我尝试了和,并将其设置为带有参数。 它不仅不能将数据序列化为整数,

  • 我正在为Kafka0.9.0.0做Kafka快速入门。 我让zookeeper在监听,因为我运行了 只有一个代理在处侦听,因为我运行了 我有一个制作人在主题“测试”上发帖,因为我跑了 当我运行旧的API使用者时,它通过运行 但是,当我运行新的API使用者时,我在运行时没有得到任何东西 是否可以使用新的API从控制台使用者订阅主题?我该怎么修好它?

  • 我们有一个服务器,负责处理消息的生成和消费。我们有4台笔记本电脑,所有带有confluent的Mac都运行相同的命令行。。。 /kafka avro控制台使用者--从一开始--引导服务器0.0.0.0:9092,0.0.0.0:9092--主题主题名称--属性schema.registry.url=http://0.0.0.0:8081 4台笔记本电脑中有3台没有问题使用这些消息,但是第四台不会。

  • java 我正在使用控制中心来检查这个主题的消费者,并跟踪正在消费的数据。在运行这个应用程序时,它与Kafka和所有分区都连接得很好,我可以在控制中心看到所有的数据都被提取了,但在我的java控制台中没有打印任何数据。但是我注意到,在向Kafka发送一些新数据时,它会在java控制台中打印出来(即,在运行我的消费者后将新数据发送给Kafka)。它应该是这样的吗?还是我做错了什么?根据我的理解,Ka