diff --git a/changes/1316-kinesis-firehose-errors b/changes/1316-kinesis-firehose-errors new file mode 100644 index 0000000000..ebe17b1578 --- /dev/null +++ b/changes/1316-kinesis-firehose-errors @@ -0,0 +1 @@ +* Fix printing of failed record count in AWS Kinesis/Firehose logging plugins. diff --git a/server/logging/firehose.go b/server/logging/firehose.go index 5a24dc254d..44f1413de9 100644 --- a/server/logging/firehose.go +++ b/server/logging/firehose.go @@ -178,7 +178,7 @@ func (f *firehoseLogWriter) putRecordBatch(try int, records []*firehose.Record) return errors.Errorf( "failed to put %d records, retries exhausted. First error: %s", - output.FailedPutCount, errMsg, + *output.FailedPutCount, errMsg, ) } diff --git a/server/logging/kinesis.go b/server/logging/kinesis.go index cdf40330eb..092732f9c4 100644 --- a/server/logging/kinesis.go +++ b/server/logging/kinesis.go @@ -186,7 +186,7 @@ func (k *kinesisLogWriter) putRecords(try int, records []*kinesis.PutRecordsRequ return errors.Errorf( "failed to put %d records, retries exhausted. First error: %s", - output.FailedRecordCount, errMsg, + *output.FailedRecordCount, errMsg, ) }