From 741e3884e62d1f8183203649e928e233df98c6c3 Mon Sep 17 00:00:00 2001
From: maxuntr <33737845+maxuntr@users.noreply.github.com>
Date: Tue, 11 May 2021 17:16:58 -0400
Subject: [PATCH] Kinesis_consumer input plugin - fix repeating parser error
 (#9169)

---
 plugins/inputs/kinesis_consumer/kinesis_consumer.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/plugins/inputs/kinesis_consumer/kinesis_consumer.go b/plugins/inputs/kinesis_consumer/kinesis_consumer.go
index 64822c2d7..57b199831 100644
--- a/plugins/inputs/kinesis_consumer/kinesis_consumer.go
+++ b/plugins/inputs/kinesis_consumer/kinesis_consumer.go
@@ -230,8 +230,8 @@ func (k *KinesisConsumer) connect(ac telegraf.Accumulator) error {
 			}
 			err := k.onMessage(k.acc, r)
 			if err != nil {
-				k.sem <- struct{}{}
-				return consumer.ScanStatus{Error: err}
+				<-k.sem
+				k.Log.Errorf("Scan parser error: %s", err.Error())
 			}
 
 			return consumer.ScanStatus{}