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{}