You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2019/04/25 17:17:01 UTC
[kafka] branch 2.2 updated: MINOR: Do not log retriable offset
commit exceptions as errors (#5904)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push:
new 725e184 MINOR: Do not log retriable offset commit exceptions as errors (#5904)
725e184 is described below
commit 725e184eead12765c0b559a4d84cb567c4e3665d
Author: Yaroslav Klymko <t3...@users.noreply.github.com>
AuthorDate: Thu Apr 25 19:10:42 2019 +0200
MINOR: Do not log retriable offset commit exceptions as errors (#5904)
Reviewers: Jason Gustafson <ja...@confluent.io>
---
.../kafka/clients/consumer/internals/ConsumerCoordinator.java | 6 +++++-
1 file changed, 5 insertions(+), 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
index 228cc66..dbd72c1 100644
--- 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 final class ConsumerCoordinator extends AbstractCoordinator {
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));