From a9b477351644a5f32a9e38bffb33a2f69c9d9557 Mon Sep 17 00:00:00 2001
From: "joy.zhou" <joy.zhou@ucloud.cn>
Date: Tue, 16 Jul 2019 15:21:20 +0800
Subject: [PATCH] update

---
 plugins/kafka/kafka.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/plugins/kafka/kafka.go b/plugins/kafka/kafka.go
index 2f4d49e..ce491c3 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"
@@ -90,7 +89,7 @@ func Publish(e *plugins.Elements) {
 		log.Error("error action: ", zap.String("action", e.Action))
 		return
 	}
-	fmt.Println("publish kafka: ", topic, key)
+	// fmt.Println("publish kafka: ", topic, key)
 	err := publish(topic, key, e)
 	if err != nil {
 		log.Error("publish kafka error: ", zap.Error(err))