MINOR: Do not log retriable offset commit exceptions as errors (#5904)

Reviewers: Jason Gustafson <[email protected]>
apache · Apr 25, 2019 · 725e184 · 725e184
1 parent 0589810
commit 725e184
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
@@ -809,7 +809,11 @@ public void handle(OffsetCommitResponse commitResponse, RequestFuture<Void> futu
                 if (error == Errors.NONE) {
                     log.debug("Committed offset {} for partition {}", offset, tp);
                 } else {
-                    log.error("Offset commit failed on partition {} at offset {}: {}", tp, offset, error.message());
+                    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));