aio-libs / aio-libs/aiokafka

Regarding Kafka Connection

Abierto
#976 0 comentarios 0 reacciones 0 asignados Ver en GitHub
question
Lenguaje dominante
Python
Estrellas
1.4k
Forks
269
Merge medio
1 d 1 h
PR fusionados (30 d)
6

Descripción

I am using Kafka in my software.
It is consuming messages from kafka topic continuously.
I am not closing the connection but starting and stopping the Kafka Consumer and Producer
Sometimes, kafka consumer is getting stuck with unknown reason.
I am restarting my software, it is working fine because it starts establishing connection again.
Is there any way to handle the exception on continuously running function?
I tried to put the function in try and except block but it is not consuming messages and not able to connect with the Kafka.

Thanks in Advance :)

Guía de contribución

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.