From 59b10c9d14b95c8cae88b6165d362712905a0824 Mon Sep 17 00:00:00 2001 From: Yaroslav Klymko Date: Mon, 12 Nov 2018 12:32:39 +0100 Subject: [PATCH 1/2] Not log retriable exceptions as errors --- .../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 afb17f8144b8e..729011cd088e0 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 void handle(OffsetCommitResponse commitResponse, RequestFuture 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)); From 3304bcec752230eeae4d381d30465e6595cd0854 Mon Sep 17 00:00:00 2001 From: Yaroslav Klymko Date: Mon, 7 Jan 2019 17:46:28 +0100 Subject: [PATCH 2/2] trigger build