• Jobs
  • About Us
  • professionals
    • Home
    • Jobs
    • Courses and challenges
  • business
    • Home
    • Post vacancy
    • Our process
    • Pricing
    • Assessments
    • Payroll
    • Blog
    • Sales
    • Salary Calculator

0

162
Views
Que pasa si no cierro el productor kafka

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

about 3 years ago · Santiago Trujillo
1 answers
Answer question

0

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.

about 3 years ago · Santiago Trujillo Report
Answer question
Find remote jobs

Discover the new way to find a job!

Top jobs
Top job categories
Business
Post vacancy Pricing Our process Sales
Legal
Terms and conditions Privacy policy
© 2025 PeakU Inc. All Rights Reserved.

Andres GPT

Recommend me some offers
I have an error