Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Producer respects Context passed to Send() and SendAsync() when appying backpressure #534

Merged
merged 1 commit into from
Jun 25, 2021
Merged

Producer respects Context passed to Send() and SendAsync() when appying backpressure #534

merged 1 commit into from
Jun 25, 2021

Commits on Jun 24, 2021

  1. Producer respects Context passed to Send() and SendAsync() when apply… 

    …ing backpressure

Previously, the Producer ignored the context passed to Send() and
SendAsync().

Now, the Producer respects the context in the case where the
ProducerOptions.MaxPendingMessages limit is reached.  In this case, the
producer will block until a permit for sending the message is available or
until the context expires, whichever comes first.

Failures to send messages due to context expiration are communicated to
callers via the existing TimeoutError error code.

Signed-off-by: Daniel Ferstay <dferstay@splunk.com>
    Daniel Ferstay committed Jun 24, 2021
    Configuration menu
    Copy the full SHA
    4b2bfbb View commit details
    Browse the repository at this point in the history