diff --git a/utils/pulsar.go b/utils/pulsar.go index d18ed89..4f2872b 100644 --- a/utils/pulsar.go +++ b/utils/pulsar.go @@ -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() }