[QUESTION] How to close connection if Kafka server isn't responding?

aio-libs / aiokafka

asyncio client for kafka

http://aiokafka.readthedocs.io/

Apache License 2.0

1.08k stars 224 forks source link

Open conradogarciaberrotaran opened 3 weeks ago

conradogarciaberrotaran commented 3 weeks ago

Hi! I want to close both a producer and consumer when Kafka server isn't responding anymore. If I do

await producer.stop()

await consumer.stop()

It will try to flush, but since the server isn't online, it won't close.

Any suggestions?