Will active (in-flight) consumer.getmany() block when partition rebalancing is initiated?

[gh-andre]

The docs describe that subsequent consumer.getmany() will block while on_partitions_revoked/on_partitions_assigned are being called, but it's not clear how would consumer.getmany() that is actively fetching records within timeout_ms behave.

https://aiokafka.readthedocs.io/en/stable/consumer.html#consumer-groups-and-topic-subscriptions

Looking at the code, it seems that an active consumer.getmany() call will also block, if I interpret this code correctly. Am I reading this right?

    async def fetched_records(self, partitions, timeout=0, max_records=None):
        while True:
            if self._subscriptions.reassignment_in_progress:
                await self._subscriptions.wait_for_assignment()

https://github.com/aio-libs/aiokafka/blob/master/aiokafka/consumer/fetcher.py#L1126C23-L1126C64

Thanks!