Kafka向主题发送消息时出错
我是Kafka的新手，当我试图发送信息到我得到的主题下面的错误。有人能帮我一下吗？
[2018-09-23 13:37:56,613]警告[Producer Clientid=Console-Producer]无法建立到节点-1的连接。代理可能不可用。（org.apache.kafka.clients.NetworkClient）
共有1个答案
如果您在云服务中运行Kafka，那么您需要适当地配置侦听器。几乎可以肯定，您的客户端正在连接到代理，但在代理返回的元数据中，您的外部客户端无法访问云网络的内部IP。
本文对此进行了解释，并提供了解决方案:https://rmoff.net/2018/08/02/kafka-listeners-explaned/
-
我有一个问题与产生的消息Kafka的主题。 我使用来自外部供应商的Kafka管理服务，所以我问他经纪人的状况，他说一切都好。顺便说一句，它发生在三个不同的Kafka实例上。Kafka客户端版本也无关紧要-0.11.0.0和2.0.1都有。
-
我正在使用kafka java客户端和kafka服务器。 我的代码： Kafka马纳格 当我的循环长度如果在1000左右（在类)时，我就能成功地向Kafka主题发送数据。 但当我的循环长度为1或小于10时，我无法向Kafka主题发送数据。注意我没有得到任何错误。 根据我的发现，如果我想发送一个单一的消息到Kafka主题，根据这个程序我得到了成功的消息，但从来没有得到一个关于我的主题的消息。 但是如
-
我在向我的Kafka主题发送序列化XML时遇到问题。每当我运行我的代码时，我都不会收到任何异常或错误消息，但我仍然无法在Kafka主题中看到我的任何消息。 我的Kafka制作人设置如下： 当我运行代码时，我得到： 知道怎么做吗？提前谢谢！
-
我有一个应用程序，它定期生成原始JSON消息数组。我能够使用avro-tools将其转换为Avro。我这样做是因为由于Kafka-Connect JDBC接收器的限制，我需要消息包含模式。我可以在记事本上打开这个文件，看到它包括模式和几行数据。 现在，我想将其发送到我的中央Kafka代理，然后使用Kafka Connect JDBC接收器将数据放入数据库。我很难理解我应该如何将这些Avro文件发送
-
我们需要从一个主题中获取消息，然后进行一些扩展，然后将消息发布到另一个主题。以下是活动 消费者-消费信息 丰富-丰富了消费的信息 制作人-将丰富的信息发布到其他主题 我正在使用Spring Cloud kafka绑定器，一切正常。最近我们引入了幂等生产者并包含transactionIdPrefix属性，我们观察到出站通道开始在主题中发送2条消息，因为它应该只发送一条消息。一条具有实际json值的消
-
我无法将KafkaProducer使用java从Windows（主机操作系统）上的eclipse发送到运行在Hortonworks沙箱上的kafka主题。我的java代码如下所示 当我运行这个java代码时没有错误，它只是打印消息的索引，在本例中只有0，然后终止，我无法在hortonworks沙箱的cmd接口上的console-consumer中看到0。 这是pom.xml依赖项 我可以从制片人那