billowqiu commented on pull request #712:
URL: https://github.com/apache/pulsar-client-go/pull/712#issuecomment-1016476988
```
var err error
var msgID MessageID
var callbackCalledCount int
var arr [5]error
p.internalSendAsync(ctx, msg, func(ID MessageID, message
*ProducerMessage, e error) {
err = e
msgID = ID
arr[callbackCalledCount] = e
callbackCalledCount += 1
if callbackCalledCount > 1 {
p.log.Infof("callback more than once for msgid %v, err:
%v, count %d", ID, arr, callbackCalledCount)
}
wg.Done()
}, true)
```
time="2022-01-19T21:24:14+08:00" level=info msg="callback more than once for
msgid <nil>, err: [<nil> message send timeout: TimeoutError <nil> <nil> <nil>],
count 2" producerID=237 producer_name=xxxxx"
time="2022-01-19T21:23:09+08:00" level=info msg="callback more than once for
msgid 684097:3722889:0, err: [message send timeout: TimeoutError <nil> <nil>
<nil> <nil>], count 2" producerID=1
producer_name=cmq_11.149.254.205_64ee3ab1-792a-11ec-b623-5254001f63ee
topic="xxxx"
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
