mjsax opened a new pull request, #23342: URL: https://github.com/apache/kafka/pull/23342
Adds LagDrivenAssignmentRefiner, the first actual implementation of the refiner seam: it withholds a stateful task from its new owner and hands that member a warm-up task instead, until the member reports a lag within acceptable.recovery.lag. Tasks with no state to restore first -- stateless ones, ones moving within a process, and ones whose hand-over already started -- are let through directly, and num.warmup.replicas caps how many warm-ups are handed out at a time. It lives in main, next to MockAssignor, so that a streams integration test can load it: streams:integration-tests depends on group-coordinator main only. Its javadoc spells out what it does not do that a real refiner has to, so it is not mistaken for the derivation we intend to ship. Coverage is the derivation in isolation plus one round trip through the coordinator -- plant, catch up, revoke, in-place promotion -- which is what shows the refiner, the seam and the reconciler compose. -- 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]
