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:
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
Debe llamar a Producer.flush()
antes de llamar a Producer.close()
. Esta es una llamada de bloqueo y no regresará antes de que se envíen todos los registros.
Si no llama a close()
, dependiendo de la implementación/lenguaje, podría terminar con fugas de recursos/memoria.