From d1aa932ceeed70abf16de2663438b48ce1b20d71 Mon Sep 17 00:00:00 2001 From: TiganeteaRobert Date: Fri, 26 Aug 2022 11:49:45 +0300 Subject: [PATCH] Kinesis source logging wrong error message (closes #209) --- pkg/source/kinesis/kinesis_source.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/source/kinesis/kinesis_source.go b/pkg/source/kinesis/kinesis_source.go index f50705d0..d164a756 100644 --- a/pkg/source/kinesis/kinesis_source.go +++ b/pkg/source/kinesis/kinesis_source.go @@ -269,7 +269,7 @@ func (ks *kinesisSource) Read(sf *sourceiface.SourceFunctions) error { case <-time.After(10 * time.Second): // Append errors and crash multierror.Append(kinesisPullErr, errors.Errorf("wg.Wait() took too long, forcing app close.")) - ks.log.WithFields(log.Fields{"error": err}).Fatal(err) + ks.log.WithFields(log.Fields{"error": kinesisPullErr}).Fatal(kinesisPullErr) } // Return kinesisPullErr if we have one