From 0980109fdf6856faba547a4c5bbe9f115415385b Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Mon, 15 Jul 2019 19:15:02 +0800 Subject: [PATCH] dd --- plugins/kafka/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/kafka/kafka.go b/plugins/kafka/kafka.go index 5b93b16..3f24a6f 100644 --- a/plugins/kafka/kafka.go +++ b/plugins/kafka/kafka.go @@ -94,7 +94,7 @@ func Publish(e *plugins.Elements) { if err != nil { log.Error("publish kafka error: ", zap.Error(err)) } - fmt.Println("------------") + fmt.Println("------------", topic) match, _ := regexp.MatchString(_ThingModelTopicRegexp, topic) if match {