Skip to content

Commit 8dab352

Browse files
committedJan 30, 2025·
change log level for message about fencing
1 parent 28833c4 commit 8dab352

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed
 

‎clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -713,7 +713,7 @@ public void onPollTimerExpired() {
713713
*/
714714
public void onFenced() {
715715
if (state == MemberState.PREPARE_LEAVING) {
716-
log.info("Member {} with epoch {} got fenced but it is already preparing to leave " +
716+
log.debug("Member {} with epoch {} got fenced but it is already preparing to leave " +
717717
"the group, so it will stop sending heartbeat and won't attempt to send the " +
718718
"leave request or rejoin.", memberId, memberEpoch);
719719
finalizeLeaving();

0 commit comments

Comments
 (0)