Kinesis_consumer input plugin - fix repeating parser error (#9169)
This commit is contained in:
parent
8b9883e2ec
commit
741e3884e6
|
|
@ -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{}
|
||||
|
|
|
|||
Loading…
Reference in New Issue