On 29.04.20 09:18, Benoit Delbosc wrote: >> 2) So in Kafka 2.0 we introduced poll(Duration) which would practically be >> more strict in respecting the passed in timeout. It means, it could return >> while we are still in the middle of a rebalance. At the same time we >> deprecated the old overloaded function but we did not delete it, for users >> who do want blocking behavior and do not care about the potential long >> polling. > I think this is the precious explanation that is missing in the poll > Javadoc, it is important to understand that in the middle of a rebalance > commitSync should not be invoked.
FYI, I have created ticket for this purpose: https://issues.apache.org/jira/browse/KAFKA-9978 Regards ben