lianetm commented on code in PR #22747:
URL: https://github.com/apache/kafka/pull/22747#discussion_r3587082380
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##########
@@ -1223,9 +1227,14 @@ private void onFailure(final long currentTimeMs,
" anymore.", responseError);
future.completeExceptionally(exception);
} else if (responseError == Errors.STALE_MEMBER_EPOCH) {
- log.error("OffsetFetch failed with {} and the consumer is not
part " +
- "of the group anymore (it probably left the group, got
fenced" +
- " or failed). The request cannot be retried and will
fail.", responseError);
+ if (memberInfo.memberEpoch.isPresent()) {
+ log.debug("OffsetFetch failed with {}. The member has a
newer epoch, so the " +
Review Comment:
"The member has a newer epoch" is not something we can be sure of here
really (the new epoch comes in a HB response, but we don't have a way to now if
that happened already or this epoch is the same stale one). At this point we
only know that the member is still in the group, so ... the request will be
retried with the new epoch if there is time.
--
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]
