[FLINK-7300] Demote ERROR to WARN on Commit Failure in KafkaConsumer

Committing the offset to Kafka can fail for various reasons, this is not always an error because Flink will keep processing just fine.
amuraru · Oct 26, 2017 · dfbf83f · dfbf83f
1 parent a9743eb
commit dfbf83f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ase/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java b/...ase/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
@@ -534,7 +534,7 @@ public void onSuccess() {
 
  @Override
  public void onException(Throwable cause) {
- LOG.error("Async Kafka commit failed.", cause);
+ LOG.warn("Async Kafka commit failed.", cause);
  failedCommits.inc();
  }
  };