dajac commented on PR #16686: URL: https://github.com/apache/kafka/pull/16686#issuecomment-2406674943
@chia7712 I haven't followed all the conversation in this PR but I have an opinion about your last statement. > Do we need to align all behaviors between the classic consumer and the async consumer? In this case, it would be simpler if ConsumerRebalanceListener could be executed by a non-user thread, similar to how the producer's callback works. I think that we should keep the new consumer backward compatible with the old one. It has been the goal since the beginning in order to facilitate the upgrade from the old to the new one. If we start to change the behaviour of some APIs, it will be a mess for our users because they will have to reason about whether they use the new or the old all the time. Another point that I would like to mention about `ConsumerRebalanceListener` is that it is very common to actually call the consumer in the listener to manually commit offset for instance. As you know, the Consumer is not supposed to be called from different threads at the moment. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
