kumarpritam863 commented on PR #17255: URL: https://github.com/apache/kafka/pull/17255#issuecomment-2468444787
@dajac no worries and thanks for the review. The invokePartitionRevoked has the access to the revoked partitions as we have calculated them beforehand and it can use that to commit its pending states. I am sorry if I am missing something here. I got this thing as we do not have the updated state in the close method and we may need to perform some operation like electing and revoking a task as leader based on a certain partition it has. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
