This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from cfa0b416efb MINOR: Remove metrics attribute from StreamsGroup (#20559)
add 848e3d0092b KAFKA-19722: Adding missing metric assigned-partitions for
new consumer (#20557)
No new revisions were added by this update.
Summary of changes:
.../internals/ConsumerMembershipManager.java | 2 +-
.../internals/StreamsMembershipManager.java | 2 +-
.../consumer/internals/SubscriptionState.java | 2 +-
.../metrics/ConsumerRebalanceMetricsManager.java | 23 +++++++-
.../kafka/clients/consumer/KafkaConsumerTest.java | 31 +++++++++++
.../internals/ConsumerMembershipManagerTest.java | 13 ++++-
.../internals/StreamsMembershipManagerTest.java | 10 ++++
.../ConsumerRebalanceMetricsManagerTest.java | 63 ++++++++++++++++++++++
8 files changed, 141 insertions(+), 5 deletions(-)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/ConsumerRebalanceMetricsManagerTest.java
