MINOR: Do not log retriable offset commit exceptions as errors
Reviewers: Jason Gustafson
@@ -822,8 +822,12 @@ public final class ConsumerCoordinator extends AbstractCoordinator {
Errors error = entry.getValue();
if (error == Errors.NONE) {
log.debug("Committed offset {} for partition {}", offset, tp);
+ } else {
+ if (error.exception() instanceof RetriableException) {
+ log.warn("Offset commit failed on partition {} at offset {}: {}", tp, offset, error.message());
} else {
log.error("Offset commit failed on partition {} at offset {}: {}", tp, offset, error.message());
+ }
if (error == Errors.GROUP_AUTHORIZATION_FAILED) {
future.raise(new GroupAuthorizationException(groupId));
