This commit is contained in:
zhiqiang feng
2021-02-01 17:46:20 +08:00
parent 133c80088c
commit 5f3334ec87
+2 -1
View File
@@ -46,9 +46,10 @@ func PulsarSend(data string) error {
Payload: []byte(data),
})
if err == nil {
Log.Info("send ", zap.Any("id", id))
Log.Info("send to pulsar", zap.Any("id", id))
break
}
Log.Error("error in produce message", zap.Error(err))
closeClient()
create()
}