向kafka主题发送消息时的TimeoutException
我有一个问题与产生的消息Kafka的主题。
我使用来自外部供应商的Kafka管理服务，所以我问他经纪人的状况，他说一切都好。顺便说一句，它发生在三个不同的Kafka实例上。Kafka客户端版本也无关紧要-0.11.0.0和2.0.1都有。
共有1个答案
我刚刚查看了版本2.0.x的Kafka文档，我想说，由于缺省设置和消息摄入负载低，您正面临此错误。
让我们试着剖析您的错误消息：
timeoutexception：从批处理创建加上逗留时间开始，已过期6条记录，用于某个主题-1：30056毫秒
-
null
在类似的行中，要修复此错误，可以增加request.timeout.ms或减少batch.size或两者兼而有之。
希望这能有所帮助！
-
我是Kafka的新手，当我试图发送信息到我得到的主题下面的错误。有人能帮我一下吗？ [2018-09-23 13:37:56,613]警告[Producer Clientid=Console-Producer]无法建立到节点-1的连接。代理可能不可用。（org.apache.kafka.clients.NetworkClient）
-
我正在使用kafka java客户端和kafka服务器。 我的代码： Kafka马纳格 当我的循环长度如果在1000左右（在类)时，我就能成功地向Kafka主题发送数据。 但当我的循环长度为1或小于10时，我无法向Kafka主题发送数据。注意我没有得到任何错误。 根据我的发现，如果我想发送一个单一的消息到Kafka主题，根据这个程序我得到了成功的消息，但从来没有得到一个关于我的主题的消息。 但是如
-
我无法将KafkaProducer使用java从Windows（主机操作系统）上的eclipse发送到运行在Hortonworks沙箱上的kafka主题。我的java代码如下所示 当我运行这个java代码时没有错误，它只是打印消息的索引，在本例中只有0，然后终止，我无法在hortonworks沙箱的cmd接口上的console-consumer中看到0。 这是pom.xml依赖项 我可以从制片人那
-
我在向我的Kafka主题发送序列化XML时遇到问题。每当我运行我的代码时，我都不会收到任何异常或错误消息，但我仍然无法在Kafka主题中看到我的任何消息。 我的Kafka制作人设置如下： 当我运行代码时，我得到： 知道怎么做吗？提前谢谢！
-
我有一个应用程序，它定期生成原始JSON消息数组。我能够使用avro-tools将其转换为Avro。我这样做是因为由于Kafka-Connect JDBC接收器的限制，我需要消息包含模式。我可以在记事本上打开这个文件，看到它包括模式和几行数据。 现在，我想将其发送到我的中央Kafka代理，然后使用Kafka Connect JDBC接收器将数据放入数据库。我很难理解我应该如何将这些Avro文件发送
-
是否可以验证/筛选发送到Kafka主题的消息？