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 {