Daniel Gellert

@wbarnha I am not sure this is correlated but we had the issue that our broker was unavailable for some time. Then the heartbeat failed and the coordinator has been...

Yes sorry I couldn't yet wrap my head around this part so far. Thanks for your work ☺️

What's also strange is that I have a log in the following order. Fetch request for topic with Highwater and last_stable_offset 694 After that I get a log records added...

Found some discussions about this in the underlying aiokafka lib that might be related: https://github.com/aio-libs/aiokafka/issues/625 https://github.com/aio-libs/aiokafka/issues/575 https://github.com/aio-libs/aiokafka/issues/727 Maybe we should check our `on_partitions_revoked` callback.

Within the [aiokafka documentation](https://aiokafka.readthedocs.io/en/stable/kafka-python_difference.html#rebalances-are-happening-in-the-background) there is this part: _It is quite critical to provide [ConsumerRebalanceListener](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.abc.ConsumerRebalanceListener) if you need to control rebalance start and end moments. In that case set the...

Looks like the monitor is a sensor implementation and reacts to events. You can provide a Monitor on app init so you might be able to create a custom one...