You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by lu...@apache.org on 2024/02/02 14:06:49 UTC
(kafka) branch trunk updated (be92ac521f2 -> f0087ac6a8a)

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 be92ac521f2 KAFKA-10047: Unnecessary widening of (int to long) scope in FloatSerializer (#9351)
     add f0087ac6a8a KAFKA-16115: Adding missing heartbeat metrics (#15216)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/consumer/KafkaConsumer.java      |  2 +-
 .../consumer/internals/AsyncKafkaConsumer.java     |  7 +-
 .../consumer/internals/CommitRequestManager.java   | 35 ++-------
 .../consumer/internals/ConsumerCoordinator.java    |  4 +-
 .../consumer/internals/ConsumerDelegate.java       |  1 +
 .../ConsumerRebalanceListenerInvoker.java          | 14 ++--
 .../clients/consumer/internals/ConsumerUtils.java  |  1 +
 .../internals/HeartbeatRequestManager.java         | 19 ++++-
 .../consumer/internals/LegacyKafkaConsumer.java    |  1 +
 .../consumer/internals/RequestManagers.java        |  3 +-
 .../internals/metrics/AbstractConsumerMetrics.java | 29 --------
 .../internals/metrics/HeartbeatMetricsManager.java | 77 +++++++++++++++++++
 .../{ => metrics}/KafkaConsumerMetrics.java        | 10 ++-
 .../metrics/OffsetCommitMetricsManager.java        | 62 +++++++++++++++
 .../metrics/RebalanceCallbackMetrics.java          | 61 ---------------
 .../metrics/RebalanceCallbackMetricsManager.java   | 87 ++++++++++++++++++++++
 .../internals/CommitRequestManagerTest.java        |  9 ++-
 .../consumer/internals/ConsumerTestBuilder.java    |  7 +-
 .../internals/HeartbeatRequestManagerTest.java     | 84 ++++++++++++++++-----
 .../internals/KafkaConsumerMetricsTest.java        |  1 +
 .../internals/MembershipManagerImplTest.java       |  4 +-
 .../metrics/HeartbeatMetricsManagerTest.java       | 62 +++++++++++++++
 .../metrics/OffsetCommitMetricsManagerTest.java    | 55 ++++++++++++++
 .../RebalanceCallbackMetricsManagerTest.java       | 52 +++++++++++++
 .../kafka/tools/consumer/group/GroupState.java     | 35 ---------
 25 files changed, 517 insertions(+), 205 deletions(-)
 delete mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/AbstractConsumerMetrics.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java
 rename clients/src/main/java/org/apache/kafka/clients/consumer/internals/{ => metrics}/KafkaConsumerMetrics.java (93%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/OffsetCommitMetricsManager.java
 delete mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceCallbackMetrics.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceCallbackMetricsManager.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManagerTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/OffsetCommitMetricsManagerTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceCallbackMetricsManagerTest.java
 delete mode 100644 tools/src/main/java/org/apache/kafka/tools/consumer/group/GroupState.java