From 4de3308aba97f073ea9acd532db80c2c3d4b282b Mon Sep 17 00:00:00 2001 From: AntonVasant Date: Sat, 22 Nov 2025 11:44:40 +0530 Subject: [PATCH 1/2] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager --- .../consumer/internals/AbstractMembershipManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java index c93a844ff9be5..041de31bab549 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java @@ -635,9 +635,9 @@ private void clearAssignmentAndLeaveGroup() { } /** - * Reset member epoch to the value required for the leave the group heartbeat request, and - * transition to the {@link MemberState#LEAVING} state so that a heartbeat request is sent - * out with it. + * Reset the member epoch to the value required for the leave-group heartbeat and transition to + * {@link MemberState#LEAVING} so the next heartbeat notifies the coordinator that the member is + * leaving the group. * * @param dueToExpiredPollTimer True if the leave group is due to an expired poll timer. This * will indicate that the member must remain STALE after leaving, From 05c61d17dae53e75d663957ee2f6b418e66e3885 Mon Sep 17 00:00:00 2001 From: AntonVasant Date: Sat, 29 Nov 2025 09:09:47 +0530 Subject: [PATCH 2/2] MINOR: Java docs line adjustment in AbstractMembershipManager --- .../clients/consumer/internals/AbstractMembershipManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java index 041de31bab549..e93a238472508 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java @@ -636,8 +636,8 @@ private void clearAssignmentAndLeaveGroup() { /** * Reset the member epoch to the value required for the leave-group heartbeat and transition to - * {@link MemberState#LEAVING} so the next heartbeat notifies the coordinator that the member is - * leaving the group. + * {@link MemberState#LEAVING} so the next heartbeat notifies the coordinator that the member + * is leaving the group. * * @param dueToExpiredPollTimer True if the leave group is due to an expired poll timer. This * will indicate that the member must remain STALE after leaving,