From 9ec63dd8b8c607f05d9cd573635c930e6d9f3d1d Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 1 Feb 2021 17:07:52 +0800
Subject: [PATCH] create producer

---
 cmd/start.go | 3 +++
 1 file changed, 3 insertions(+)

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