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

Hi!
I want to close both a producer and consumer when Kafka server isn't responding anymore.
If I do
```python
await producer.stop()
```
```python
await consumer.stop()
```
It will try to flush, but since the server isn't online, it won't close.

Any suggestions?