From 81d4dea4bbe8f1cd300c03cf7428db35805705b9 Mon Sep 17 00:00:00 2001 From: Mark Wolfe Date: Tue, 20 Dec 2016 11:03:38 +1100 Subject: [PATCH] Adjusted metric type in line with latest changes. --- plugins/outputs/kinesis/kinesis.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/outputs/kinesis/kinesis.go b/plugins/outputs/kinesis/kinesis.go index e71617d588abe..d1725d0cbbdfe 100644 --- a/plugins/outputs/kinesis/kinesis.go +++ b/plugins/outputs/kinesis/kinesis.go @@ -175,7 +175,7 @@ func (k *KinesisOutput) Write(metrics []telegraf.Metric) error { for _, metric := range values { d := kinesis.PutRecordsRequestEntry{ - Data: []byte(metric), + Data: []byte{metric}, PartitionKey: aws.String(k.PartitionKey), } r = append(r, &d)