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

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