[QUESTION] How to detect connection issues with a consumer?

[anetbnd]

Hello,

we face issues to detect the connection status to the broker with a consumer. We have the requirement to generate a notification, if the connection to the broker is lost. But with aiokafka we cannot come up with any good concept to do that.

If we run getmany(...) the method will just return after the timeout is reached with an empty dictionary. But we don't know if the dictionary was empty because of no messages received or because of the connection get lost. Is there any way to test the connection status?