[camel-kafka-connector] branch master updated: Fixes a misplaced log error message flooding the logs w/ invalid errors

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 32d7e52  Fixes a misplaced log error message flooding the logs w/ 
invalid errors
     new 44ac753  Merge pull request #122 from orpiske/fix-bogus-aws-error
32d7e52 is described below

commit 32d7e52174c61c324987be4f6b72d204eb3365e6
Author: Otavio R. Piske <angusyo...@gmail.com>
AuthorDate: Fri Apr 10 20:22:31 2020 +0200

    Fixes a misplaced log error message flooding the logs w/ invalid errors
---
 .../source/aws/kinesis/CamelSourceAWSKinesisITCase.java               | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tests/src/test/java/org/apache/camel/kafkaconnector/source/aws/kinesis/CamelSourceAWSKinesisITCase.java
 
b/tests/src/test/java/org/apache/camel/kafkaconnector/source/aws/kinesis/CamelSourceAWSKinesisITCase.java
index e75acb4..2cd85cb 100644
--- 
a/tests/src/test/java/org/apache/camel/kafkaconnector/source/aws/kinesis/CamelSourceAWSKinesisITCase.java
+++ 
b/tests/src/test/java/org/apache/camel/kafkaconnector/source/aws/kinesis/CamelSourceAWSKinesisITCase.java
@@ -148,9 +148,9 @@ public class CamelSourceAWSKinesisITCase extends 
AbstractKafkaTest {
                  It may take some time for the local Kinesis backend to be 
fully up - even though the container is
                  reportedly up and running. Therefore, it tries a few more 
times
                  */
-
-                LOG.error("Failed to put the records: {}", e.getMessage(), e);
+                LOG.trace("Failed to put the records: {}. Retrying in 2 
seconds ...", e.getMessage());
                 if (retries == 0) {
+                    LOG.error("Failed to put the records: {}", e.getMessage(), 
e);
                     throw e;
                 }