This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a334b1b6fda MINOR Fix build scan artifact name in ci-complete (#17863)
add a211ee99b57 KAFKA-17593; [7/N] Introduce CoordinatorExecutor (#17823)
No new revisions were added by this update.
Summary of changes:
.../common/runtime/CoordinatorExecutor.java | 84 ++++++
.../common/runtime/CoordinatorExecutorImpl.java | 147 ++++++++++
.../common/runtime/CoordinatorRuntime.java | 38 ++-
.../common/runtime/CoordinatorShardBuilder.java | 11 +
.../runtime/CoordinatorExecutorImplTest.java | 317 +++++++++++++++++++++
.../common/runtime/CoordinatorRuntimeTest.java | 184 +++++++++++-
.../coordinator/group/GroupCoordinatorService.java | 2 +
.../coordinator/group/GroupCoordinatorShard.java | 13 +
.../coordinator/share/ShareCoordinatorService.java | 2 +
.../coordinator/share/ShareCoordinatorShard.java | 7 +
10 files changed, 801 insertions(+), 4 deletions(-)
create mode 100644
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutor.java
create mode 100644
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImpl.java
create mode 100644
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImplTest.java
