This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 2da83ab3589 MINOR: Update OffsetResetStrategy Javadoc (#20701)
add 616b0234c88 KAFKA-19691: Add metrics corresponding to consumer
rebalance listener metrics (#20464)
No new revisions were added by this update.
Summary of changes:
.../internals/DefaultStreamsRebalanceListener.java | 41 +++-
.../streams/processor/internals/StreamThread.java | 28 +--
.../metrics/RebalanceListenerMetrics.java | 92 +++++++++
.../DefaultStreamsRebalanceListenerTest.java | 216 +++++++++++++++++++--
.../metrics/RebalanceListenerMetricsTest.java | 113 +++++++++++
5 files changed, 454 insertions(+), 36 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/RebalanceListenerMetrics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/RebalanceListenerMetricsTest.java
