squah-confluent commented on code in PR #21652:
URL: https://github.com/apache/kafka/pull/21652#discussion_r2896862494
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java:
##########
@@ -45,6 +45,18 @@
*/
public abstract class ModernGroup<T extends ModernGroupMember> implements
Group {
+ /**
+ * The target assignment metadata.
+ *
+ * @param assignmentEpoch The target assignment epoch. An assignment
epoch smaller than the
+ * group epoch means that a new assignment is
required. The
+ * assignment epoch is updated when a new
assignment is installed.
+ * @param assignmentTimestamp The time at which the target assignment
calculation finished.
+ */
+ protected static record TargetAssignmentMetadata(int assignmentEpoch, long
assignmentTimestamp) {
+ private static final TargetAssignmentMetadata NONE = new
TargetAssignmentMetadata(0, 0L);
Review Comment:
That would change the initial assignment epoch from `0` to `-1`. Are you
sure?
--
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]
