weichangdong opened a new issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690


   go mod use this version 
   
   ```
   github.com/apache/rocketmq-client-go/v2 v2.1.0
   ```
   
   ```  
   err = rocketmqclient.RocketmqProducer.SendAsync(context.Background(),
                func(ctx context.Context, result *primitive.SendResult, e 
error) {
                        if e != nil || result == nil || (result != nil && 
result.Status != primitive.SendOK) {
                                logs.Error("SendAsync SendAsync message error: 
", e, " result:", result, " msgLen:", len(string(msgByte)), " ctime:", ctime, " 
relatedUid:", relatedUid, " relatedTid:", relatedTid)
                                if result != nil {
                                        logs.Error("result:", result.String())
                                }
                                err = e
                                sendOk = false
                        } else {
                                sendOk = true
                        }
                }, rocketmqMsg)
   
   ```
   the log output
   ```
   SendAsync SendAsync message error:  <nil>  result: %!v(PANIC=String method: 
runtime error: invalid memory address or nil pointer dereference)  msgLen: 
788741  ctime: 1624901003080  relatedUid: radtatmbcpg5cemoqjs8t324l0  
relatedTid: 
   ```
   
   maxMessageSize=65536
   
   Although our setting is small, it should not panic


-- 
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]


Reply via email to