Apache Kafka：TimeoutException,然后什么都不工作
我正试图从一个生产者向另一个DC中的Kafka节点发送一个消息。生产者和消费者都设置了默认的0.10.0.0配置，并且消息大小不是很小（大约500K)。大多数情况下，我在发送消息时会遇到以下例外情况：
org.apache.kafka.common.errors.TimeoutException：包含%1条记录的批处理由于从代理为主题请求元数据时超时而过期-0 org.apache.kafka.common.errors.TimeoutException：无法在配置的最大阻塞时间60000 ms内分配内存。
在此之后，不再传输更多的消息（甚至剩余消息的回调也不会被调用）。
共有2个答案
只是想插嘴，因为我今天收到了完全相同的错误。我尝试增加request.timeout.ms，减少batch.size，甚至将batch.size设置为零。然而，一切都不奏效。
原来是因为服务器无法连接到10个Kafka集群节点中的一个。所以，我看到的是一些不适当的例外被抛出。顺便说一下，如果重要的话，我们使用的是卡夫卡0.9.0.1。
根据卡夫卡的文件：
较小的批处理大小将使批处理不那么常见，并可能降低吞吐量（批处理大小为零将完全禁用批处理）。一个非常大的批处理大小可能会更浪费内存，因为我们总是会分配一个指定批处理大小的缓冲区，以预期额外的记录。
设置batch.size=0，它将解决此问题。
-
我正在写一份简单的银行申请书。在我的程序中，我使用了while循环。如果用户输入错误，它将再次提示用户输入。 现在的问题是我无法编写任何语句。它总是显示错误（比如：unreachable语句），最终该行不会被打印出来。 我该怎么解决这个问题？ [我之所以需要使用，是因为我想打印用户输入的所有信息。] 我正在从事的项目：
-
在Java中，什么与Python的pass等效？我意识到我可以使用continue语句或不完成语句体来实现这种效果，但我喜欢使用pass语句。
-
我的配置文件是类路径的路径。至少我认为是这样。我放置了log4j。资源文件夹中的属性文件，而log4j对此不做任何处理。即使我删除了它，也不会发生错误。 任何人都可以看到，我在使用maven LoggerTest的内容： 程序输出： log4j的内容。属性： 在波姆。xml并不是什么不同寻常的东西，只是一个依赖组织。阿帕奇。登录中。log4j log4j内核2.17.2，编译器源目标是16，没有插
-
因此，我使用javafx创建了这个应用程序，它有一个登录屏幕，但我在这方面没有任何成功，我已经在这个项目的这个小部分工作了一些天，它根本不能以任何方式工作。我尝试这样做，我看了一些教程，其中大部分都是像下面的代码一样，但它对我来说不起作用，如果有人能帮我解释为什么我的标签文本没有改变(这就是我如何测试登录是否成功)，这将是很好的，下面是代码: 控制器： FXML格式
-
所以我有这个代码，叫我白痴哈哈，但是我不能让它打印7。 代码： 我需要知道如何改变与函数中的参数同名的变量。 任何帮助都将不胜感激，如果你不明白这个问题，我很乐意解释更多。
-
问题内容： 我有以下定制JPanel，并且已使用Netbeans GUI构建器将其添加到我的框架中，但是背景不会改变！我可以看到用g.fillOval（）绘制的圆圈。怎么了？ 问题答案： 如果面板“不透明”（透明），您将看不到背景色。