You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/12/09 14:39:32 UTC
[GitHub] [pulsar] codelipenghui added a comment to the discussion: Failed messages 1 with no more exception message
GitHub user codelipenghui added a comment to the discussion: Failed messages 1 with no more exception message
@Aaronzk There is an internal pending queue with 1000 messages by default for a producer. if the server-side with a slow response but the application send messages very fast that will fill up the pending queue, so by default, you will get the above exception, it's a fail-fast strategy.
Another available strategy is to block the caller thread if the pending queue filled up, you can add `.blockIfQueueFull(true)` when creating the producer.
GitHub link: https://github.com/apache/pulsar/discussions/18854#discussioncomment-4352699
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org