dajac opened a new pull request, #21350: URL: https://github.com/apache/kafka/pull/21350
This patch refactors the coordinator runtime to improve modularity by decoupling the timer and executor components: - Extract EventBasedCoordinatorTimer from CoordinatorRuntime into standalone CoordinatorTimerImpl; - Introduce CoordinatorShardScheduler interface to allow shard-scoped components (timer, executor) to schedule write operations back to the runtime within their shard's scope; - Simplify CoordinatorExecutorImpl by replacing direct runtime dependency with the new scheduler interface; -- 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]
