From 980c52c940b3877570c1541de8c87d6857a37345 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 1 Feb 2021 16:09:35 +0800
Subject: [PATCH] log message id

---
 utils/pulsar.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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