lianetm opened a new pull request, #21813: URL: https://github.com/apache/kafka/pull/21813
Apply same fix from https://github.com/apache/kafka/pull/21495 to the Streams manager. This ensures that assignment updates happen within a call to consumer.poll (even when reconciliations may complete async in the background). Done by piggybacking the assignment update the in the existing hop that was made to the app thread when a reconciliation completed (previously used to trigger callback only, now used to update assignment and run callback) -- 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]
