From 1586a67dde0faf7ce528b2e08758724073665f19 Mon Sep 17 00:00:00 2001
From: "joy.zhou" <joy.zhou@ucloud.cn>
Date: Mon, 15 Jul 2019 19:19:00 +0800
Subject: [PATCH] ddd

---
 plugins/kafka/kafka.go | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/plugins/kafka/kafka.go b/plugins/kafka/kafka.go
index 3f24a6f..b020a37 100644
--- a/plugins/kafka/kafka.go
+++ b/plugins/kafka/kafka.go
@@ -3,7 +3,6 @@ package kafka
 import (
 	"encoding/json"
 	"errors"
-	"fmt"
 	"io/ioutil"
 	"regexp"
 	"time"
@@ -94,11 +93,9 @@ func Publish(e *plugins.Elements) {
 	if err != nil {
 		log.Error("publish kafka error: ", zap.Error(err))
 	}
-	fmt.Println("------------", topic)
 
-	match, _ := regexp.MatchString(_ThingModelTopicRegexp, topic)
-	if match {
-		fmt.Println("------------11111")
+	match, _ := regexp.MatchString(_ThingModelTopicRegexp, e.Topic)
+	if match && e.Action == plugins.Publish {
 		topic := "tmodel.msg.upstream"
 		err := publish(topic, key, e)
 		if err != nil {