lianetm commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1521937262
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##########
@@ -210,12 +213,12 @@ public class MembershipManagerImpl implements
MembershipManager {
private final Map<Uuid, String> assignedTopicNamesCache;
/**
- * Topic IDs and partitions received in the last target assignment. Items
are added to this set
- * every time a target assignment is received. This is where the member
collects the assignment
- * received from the broker, even though it may not be ready to fully
reconcile due to missing
- * metadata.
+ * Topic IDs and partitions received in the last target assignment,
together with its local epoch.
+ *
+ * This member reassigned every time a new assignment is received.
Review Comment:
I don't quite get this sentence (was the intention just to start with
`Reassigned every`... I guess...?)
--
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]
