You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ca...@apache.org on 2025/03/03 09:46:26 UTC

(kafka) branch trunk updated (a04dd21f260 -> 898dcd11ad2)

This is an automated email from the ASF dual-hosted git repository.

cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from a04dd21f260 KAFKA-18613: Auto-creation of internal topics in streams group heartbeat (#18981)
     add 898dcd11ad2 MINOR: Extract HeartbeatRequestState from heartbeat request managers (#19043)

No new revisions were added by this update.

Summary of changes:
 .../internals/AbstractHeartbeatRequestManager.java |  87 +------------
 .../internals/ConsumerHeartbeatRequestManager.java |   2 +-
 .../consumer/internals/HeartbeatRequestState.java  | 113 +++++++++++++++++
 .../internals/ShareHeartbeatRequestManager.java    |   2 +-
 .../StreamsGroupHeartbeatRequestManager.java       |  61 +--------
 .../ConsumerHeartbeatRequestManagerTest.java       |   1 -
 .../internals/HeartbeatRequestStateTest.java       | 137 +++++++++++++++++++++
 .../ShareHeartbeatRequestManagerTest.java          |   8 +-
 8 files changed, 260 insertions(+), 151 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestState.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestStateTest.java