Estoy procesando xml y necesito enviar un mensaje por registro, cuando recibo el último registro cierro el productor kafka, el problema aquí es que el método de envío del productor kafka es asíncrono, por lo tanto, a veces cuando cierro el productor muestra java.lang.IllegalStateException: Cannot send after the producer is closed. He leído en alguna parte que puedo dejar el productor abierto. Mi pregunta es: ¿Qué implica, o si hay una mejor solución para esto?

---Editar---

 <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>

Imagina el siguiente escenario:

• Leemos la etiqueta y creamos el productor kafka
• Por cada elemento, leemos sus atributos, generamos un objeto json y lo enviamos a kafka usando el método de envío. -Cuando leemos el elemento llamamos al método close en el productor

Problema: el número de elementos puede ser de 80k, por lo tanto, a veces, cuando llamamos al método de desconexión, continúa enviando los mensajes de forma asíncrona. Entonces, primero debemos llamar al método de descarga, pero afecta el rendimiento