Merge pull request apache#1104 from 474903784/fix_send_async

tiger lee · web-flow · commit 49f0448ef642 · 2023-10-26T11:14:22.000+08:00
[ISSUE apache#1102] fix send async err occur panic: runtime error: invalid …
diff --git a/producer/producer.go b/producer/producer.go
@@ -405,6 +405,7 @@ func (p *defaultProducer) sendAsync(ctx context.Context, msg *primitive.Message,
 		cancel()
 		if err != nil {
 			h(ctx, nil, err)
+			return
 		}
 
 		resp := primitive.NewSendResult()

Original file line number	Diff line number	Diff line change
`@@ -405,6 +405,7 @@ func (p defaultProducer) sendAsync(ctx context.Context, msg primitive.Message,`
`405`	`405`	`cancel()`
`406`	`406`	`if err != nil {`
`407`	`407`	`h(ctx, nil, err)`
	`408`	`+ return`
`408`	`409`	`}`
`409`	`410`
`410`	`411`	`resp := primitive.NewSendResult()`