如果我不关闭kafka生产者，会发生什么？ - java

我正在处理xml，我需要为每条记录发送一条消息，当我收到最后一条记录时，我关闭了kafka生产者，这里的问题是kafka生产者的send方法是异步的，因此，有时当我关闭生产者时它抛出了java.lang.IllegalStateException: Cannot send after the producer is closed.我读过的地方可以让生产者打开。我的问题是:这意味着什么，或者对此有更好的解决方案。

---编辑---

<list>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
  <element attr1="" att2="" attr3=""/>
...
</list>

想象以下情况:

我们阅读标签并创建kafka生产者

每个元素我们读取其属性，生成一个json对象，并使用send方法将其发送到kafka。
-读取元素时，我们在生产者

中调用close方法

问题是元素的数量可能是80k，因此，有时当我们调用断开连接方法时，它会继续以异步方式发送消息。所以我们需要先调用flush方法，但这会影响性能

参考方案

您应该先调用Producer.flush()，然后再调用Producer.close()。这是一个阻塞的调用，不会在所有记录发送之前返回。

如果不调用close()，则根据实现/语言的不同，可能会导致资源/内存泄漏。

Java-搜索字符串数组中的字符串 - java

在Java中，我们是否有任何方法可以发现特定字符串是字符串数组的一部分。我可以避免出现一个循环。例如String [] array = {"AA","BB","CC" }; string x = "BB" 我想要一个if (some condition to tell wheth…

Java Scanner读取文件的奇怪行为 - java

因此，在使用Scanner类从文件读取内容时，我遇到了一个有趣的问题。基本上，我试图从目录中读取解析应用程序生成的多个输出文件，以计算一些准确性指标。基本上，我的代码只是遍历目录中的每个文件，并使用扫描仪将其打开以处理内容。无论出于何种原因，扫描程序都不会读取其中的一些文件(所有UTF-8编码)。即使文件不是空的，scanner.hasNextLine()在…

Java Globbing模式以匹配目录和文件 - java

我正在使用递归函数遍历根目录下的文件。我只想提取*.txt文件，但不想排除目录。现在，我的代码如下所示：val stream = Files.newDirectoryStream(head, "*.txt") 但是这样做将不会匹配任何目录，并且返回的iterator()是False。我使用的是Mac，所以我不想包含的噪音文件是.DS_ST…

Java RegEx中的单词边界\ b - java

我在使用\b作为Java Regex中的单词定界符时遇到困难。对于text = "/* sql statement */ INSERT INTO someTable"; Pattern.compile("(?i)\binsert\b");找不到匹配项Pattern insPtrn = Pattern.compile(&…

Java Double与BigDecimal - java

我正在查看一些使用双精度变量来存储（360-359.9998779296875）结果为0.0001220703125的代码。 double变量将其存储为-1.220703125E-4。当我使用BigDecimal时，其存储为0.0001220703125。为什么将它双重存储为-1.220703125E-4？ 参考方案 我不会在这里提及精度问题，而只会提及数字…