fix: templates

vseinstrumentiru · Feb 4, 2022 · d3de1fd · d3de1fd
1 parent 578be5a
commit d3de1fd
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/handler.kafka.tmpl b/handler.kafka.tmpl
@@ -100,6 +100,11 @@ func (r *{{.ModelNamePrivate}}Publisher) Publish(event *{{.ModelName}}Event) err
 	}
 
 	msg := message.NewMessage(event.ID.String(), payload)
+
+	if event.Meta == nil {
+ 		event.Meta = map[string]string{}
+ 	}
+
 	msg.Metadata = event.Meta
 
 	if err = r.mp.Publish(r.topic, msg); err != nil {