lianetm opened a new pull request, #21495: URL: https://github.com/apache/kafka/pull/21495
Fix to ensure that reconciled assignments are only updated in the subscription state within a call to consumer.poll Note that this fix still allows for background reconciliation progress: - reconciliations triggered from background poll attempt to resolve target assignment from metadata, request metadata as needed -> this remains unchanged with this PR - reconciliations triggered from application thread on consumer poll: attempt to resolve metadata if needed, and perform the reconciliation operations that can only happen within poll : commit, callbacks and assignment update. This PR is only fixing the assignment update bit (commit and callback were already done only triggered from consumer.poll) This fix should remove the friction on applications that were getting IllegalState when attempting seek/position on partitions the consumer.assignment(). Added integration test to validate. -- 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]
