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

[conradogarciaberrotaran]

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?