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-unsubscr...@pulsar.apache.org
