lucasbru commented on code in PR #21692:
URL: https://github.com/apache/kafka/pull/21692#discussion_r2940418713
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java:
##########
@@ -670,11 +670,29 @@ public CommitPartitionValidator validateOffsetCommit(
// the member should be using the OffsetCommit API version >= 9.
if (!isTransactional && !member.useClassicProtocol() && apiVersion <
9) {
throw new UnsupportedVersionException("OffsetCommit version 9 or
above must be used " +
- "by members using the modern group protocol");
+ "by members using the consumer group protocol");
}
- validateMemberEpoch(memberEpoch, member.memberEpoch(),
member.useClassicProtocol());
- return CommitPartitionValidator.NO_OP;
+ // For members using the classic protocol, the epoch must match the
last epoch sent
+ // in a heartbeat.
+ if (member.useClassicProtocol()) {
+ validateMemberEpoch(memberEpoch, member.memberEpoch(), true);
+ return CommitPartitionValidator.NO_OP;
+ }
Review Comment:
Not an expert on the migration code. But yeah, I also don't see a problem
with applying the same logic to classic members in mixed groups.
--
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]
