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 7ed35ab26b7 KAFKA-20134: Implement TimestampedWindowStoreWithHeaders
(5/N) (#21497)
add 244e848e019 KAFKA-20211: Add group coordinator background metrics
(#21616)
No new revisions were added by this update.
Summary of changes:
.../CoordinatorBackgroundThreadPoolExecutor.java | 77 +++++++++++++++
.../common/runtime/CoordinatorRuntimeMetrics.java | 20 ++++
.../runtime/CoordinatorRuntimeMetricsImpl.java | 96 +++++++++++++++++-
...oordinatorBackgroundThreadPoolExecutorTest.java | 107 +++++++++++++++++++++
.../runtime/CoordinatorRuntimeMetricsImplTest.java | 98 ++++++++++++++++---
.../coordinator/group/GroupCoordinatorService.java | 16 +--
.../metrics/GroupCoordinatorRuntimeMetrics.java | 2 +-
.../metrics/ShareCoordinatorRuntimeMetrics.java | 2 +-
8 files changed, 395 insertions(+), 23 deletions(-)
create mode 100644
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorBackgroundThreadPoolExecutor.java
create mode 100644
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorBackgroundThreadPoolExecutorTest.java