mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-02 14:28:34 +00:00
dd
This commit is contained in:
@@ -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 {
|
||||
|
||||
Reference in New Issue
Block a user