From e74b9facd13e43444909116e5733d5f57822beee Mon Sep 17 00:00:00 2001
From: "H.K" <47513381+matzah@users.noreply.github.com>
Date: Mon, 30 Sep 2019 10:50:40 +0800
Subject: [PATCH] fix: (#57)

topics used but not make
---
 plugins/bridge/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/bridge/kafka.go b/plugins/bridge/kafka.go
index f7f6730..54a5fa2 100644
--- a/plugins/bridge/kafka.go
+++ b/plugins/bridge/kafka.go
@@ -65,7 +65,7 @@ func (k *kafka) connect() {
 func (k *kafka) Publish(e *Elements) error {
 	config := k.kafakConfig
 	key := e.ClientID
-	var topics map[string]bool
+	topics := make(map[string]bool)
 	switch e.Action {
 	case Connect:
 		if config.ConnectTopic != "" {