diff --git a/utils/pulsar.go b/utils/pulsar.go index 96ec52c..d18ed89 100644 --- a/utils/pulsar.go +++ b/utils/pulsar.go @@ -42,10 +42,11 @@ func create() { func PulsarSend(data string) error { var err error for i := 0; i < 5; i++ { - _, err = producer.Send(context.Background(), &pulsar.ProducerMessage{ + id, err := producer.Send(context.Background(), &pulsar.ProducerMessage{ Payload: []byte(data), }) if err == nil { + Log.Info("send ", zap.Any("id", id)) break } closeClient()