You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/04/11 06:08:03 UTC
[camel-kafka-connector] branch master updated: Fixes a misplaced
log error message flooding the logs w/ invalid errors
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 <an...@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;
}