frankvicky commented on code in PR #17549:
URL: https://github.com/apache/kafka/pull/17549#discussion_r1807324925
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##########
@@ -1234,8 +1245,8 @@ protected void resetEpoch() {
protected void updateMemberEpoch(int newEpoch) {
boolean newEpochReceived = this.memberEpoch != newEpoch;
this.memberEpoch = newEpoch;
- // Simply notify based on epoch change only, given that the member
will never receive a
- // new member ID without an epoch (member ID is only assigned when it
joins the group).
+ // Simply notify based on epoch changes only, since the member will
generate a member ID
+ // at startup, and it will remain unchanged for its entire lifetime.
if (newEpochReceived) {
Review Comment:
I'm not sure if we need to update the logic here accordingly.
https://github.com/apache/kafka/blob/2267518d5bed60e2a1731712ae7cb455ea0bf8c4/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java#L1239-L1245
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
