【发布时间】:2021-02-06 23:08:19
【问题描述】:
Note: after creating a KafkaProducer you must always close() it to avoid resource leaks.
浏览了文档,但无法理解。谁能解释一下它的真正含义。
【问题讨论】:
标签: java apache-kafka kafka-producer-api
Note: after creating a KafkaProducer you must always close() it to avoid resource leaks.
浏览了文档,但无法理解。谁能解释一下它的真正含义。
【问题讨论】:
标签: java apache-kafka kafka-producer-api
这意味着你必须在它上面使用try-with-resource,或者在你使用完这个生产者之后明确地使用close。 Producer 实现 Closable 并在调用 #close() 方法时执行许多清理例程,例如停止线程和关闭 i/o 流。 Consumer 也是如此。
一般来说,资源泄漏可能会导致性能问题,例如阻止 GC 正常工作、耗尽文件处理程序的可用限制、导致网络速度变慢等等。
【讨论】: