diff --git a/cmd/test.go b/cmd/test.go index 521f609..31b468b 100644 --- a/cmd/test.go +++ b/cmd/test.go @@ -40,6 +40,9 @@ func test() { if err != nil { println("create database error ", err) } + + utils.CreateProducer(pulsarUrl, topic, name) + utils.ClosePulsar() } func init() {