collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-05-02 14:28:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
joy.zhou
2019-07-16 15:21:20 +08:00
parent f671e9f4b7
commit a9b4773516
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
plugins/kafka/kafka.go
View File

@@ -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))