fix kafka assignment to nil map (#867)

fixes #866
2024-04-21 12:32:02 +00:00 · 2020-12-07 21:07:06 +03:00
parent f6a4170615
commit 87bdb4da00
1 changed files with 1 additions and 1 deletions
@@ -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, ", ")
 		}