Browse Source

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

Reviewers: Jason Gustafson <jason@confluent.io>
pull/6583/head
Yaroslav Klymko 6 years ago committed by Jason Gustafson
parent
commit
f6c59df07e
  1. 4
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java

4
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java

@ -822,8 +822,12 @@ public final class ConsumerCoordinator extends AbstractCoordinator { @@ -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));

Loading…
Cancel
Save