From 4b815e5935dd7fb7b60a58bcca4291e8cb875b53 Mon Sep 17 00:00:00 2001 From: Michal Posacki Date: Tue, 30 Mar 2021 08:28:48 +0200 Subject: [PATCH] change logging level (#799) --- .../java/software/amazon/kinesis/lifecycle/ProcessTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java index b3ba8a7d..2d05488b 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java @@ -217,7 +217,7 @@ public class ProcessTask implements ConsumerTask { } catch (Exception e) { log.error("ShardId {}: Application processRecords() threw an exception when processing shard ", shardInfoId, e); - log.error("ShardId {}: Skipping over the following data records: {}", shardInfoId, records); + log.debug("ShardId {}: Skipping over the following data records: {}", shardInfoId, records); } finally { MetricsUtil.addLatency(scope, RECORD_PROCESSOR_PROCESS_RECORDS_METRIC, startTime, MetricsLevel.SUMMARY); MetricsUtil.endScope(scope);