如果我不关闭Kafka制作人会发生什么

Question

我正在处理xml，我需要每条记录发送一条消息，当我收到最后一条记录时，我关闭了kafka生产者，这里的问题是kafka生产者的发送方法是异步的，因此，有时当我关闭生产者时，它会拖曳java.lang.IllegalStateException：在生产者关闭后无法发送。我在某个地方读到过，我可以让制片人敞开心扉。我的问题是：这意味着什么，或者是否有更好的解决方案。

-编辑-

<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的问题，有时当我们调用sresals方法时，它继续以异步方式发送消息。因此，我们需要先调用 flush 方法，但这会影响性能

Answer 1

您应该先调用生产者.flush（） 然后再调用生产者.close（）。这是一个阻止呼叫，不会在发送所有记录之前返回。

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