Soy nuevo en kafka y en kafkajs.

He creado un productor y consumidor de Kafka usando kafkaJS .

Quiero saber cómo puedo controlar lo que sucede en mi código js cuando el consumidor o el productor agotan el tiempo de conexión con el servidor kafka.

Me imagino que debe haber algún tipo de asignación de funciones en la configuración, pero hasta ahora no pude encontrar nada en los documentos.