From 87bdb4da00eedb3521963c6993da57cf53f687d3 Mon Sep 17 00:00:00 2001
From: Urban Ishimwe <urbainishimwe@gmail.com>
Date: Mon, 7 Dec 2020 20:07:06 +0200
Subject: [PATCH] fix kafka assignment to nil map (#867)

fixes #866
---
 output_kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/output_kafka.go b/output_kafka.go
index 40a2bf8..816a7be 100644
--- a/output_kafka.go
+++ b/output_kafka.go
@@ -70,7 +70,7 @@ func (o *KafkaOutput) PluginWrite(msg *Message) (n int, err error) {
 		message = sarama.StringEncoder(byteutils.SliceToString(msg.Meta) + byteutils.SliceToString(msg.Data))
 	} else {
 		mimeHeader := proto.ParseHeaders(msg.Data)
-		var header map[string]string
+		header := make(map[string]string)
 		for k, v := range mimeHeader {
 			header[k] = strings.Join(v, ", ")
 		}