This is an automated email from the ASF dual-hosted git repository.
crossoverJie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new c408a107 docs(producer): clarify SendAsync description (#1485)
c408a107 is described below
commit c408a107e339f3205902ee6a3334fcf39d6878bc
Author: Mukunda Rao Katta <[email protected]>
AuthorDate: Tue May 26 23:57:07 2026 -0700
docs(producer): clarify SendAsync description (#1485)
Co-authored-by: crossoverJie <[email protected]>
---
pulsar/producer.go | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/pulsar/producer.go b/pulsar/producer.go
index 633e761a..c8b6b09c 100644
--- a/pulsar/producer.go
+++ b/pulsar/producer.go
@@ -231,8 +231,11 @@ type Producer interface {
// producer.Send(ctx, pulsar.ProducerMessage{ Payload: myPayload })
Send(context.Context, *ProducerMessage) (MessageID, error)
- // SendAsync a message in asynchronous mode
- // This call is blocked when the `maxPendingMessages` becomes full
(default: 1000)
+ // SendAsync a message in asynchronous mode. The send operation
completes in the background
+ // and the provided callback is invoked once the broker acknowledges
the message (or when
+ // the publish fails), so the caller can continue without waiting for
the result.
+ // This call is blocked when the `maxPendingMessages` becomes full
(default: 1000) unless
+ // `DisableBlockIfQueueFull` is set to true, in which case it returns
an error immediately.
// The callback will report back the message being published and
// the eventual error in publishing
// The context passed in the call is only used for the duration of the
SendAsync call itself
