diff --git a/cmd/start.go b/cmd/start.go
index a225431..dba577b 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -89,6 +89,9 @@ func start() {
 	if tcp {
 		go utils.Listen(socketAddress)
 	}
+	if pulsar {
+		utils.CreateProducer(pulsarUrl, topic, name)
+	}
 	for utils.ServerRunning {
 		if !utils.IsPortOpen() {
 			logger.Info("try to open port")