Skip to content

Commit 6e8df29

Browse files
MINOR: Log at info level when pending member joins a group (apache#17495)
When a dynamic member joins a group, it sends two JOIN_GROUP requests. The first request doesn't have a member id and returns MEMBER_ID_REQUIRED with a broker-generated member id. The second request includes the broker-generated member id and joins the group for real. We emit a log message at info level for the first join request, but not the second. Log the second join request at info level too. Reviewers: David Jacot <[email protected]>
1 parent 25e8e4c commit 6e8df29

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -427,7 +427,7 @@ private[group] class GroupCoordinator(
427427
s"for pending member with memberId=$memberId")
428428
}
429429

430-
debug(s"Pending dynamic member with id $memberId joins group ${group.groupId} in " +
430+
info(s"Pending dynamic member with id $memberId joins group ${group.groupId} in " +
431431
s"${group.currentState} state. Adding to the group now.")
432432
addMemberAndRebalance(rebalanceTimeoutMs, sessionTimeoutMs, memberId, None,
433433
clientId, clientHost, protocolType, protocols, group, responseCallback, reason)

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4321,7 +4321,7 @@ private CoordinatorResult<Void, CoordinatorRecord> classicGroupJoinExistingMembe
43214321
groupInstanceId + " for pending member with memberId=" + memberId);
43224322
}
43234323

4324-
log.debug("Pending dynamic member with id {} joins group {} in {} state. Adding to the group now.",
4324+
log.info("Pending dynamic member with id {} joins group {} in {} state. Adding to the group now.",
43254325
memberId, group.groupId(), group.currentState());
43264326

43274327
return addMemberThenRebalanceOrCompleteJoin(

0 commit comments

Comments
 (0)