Marek Czajkowski

It's only for safeguarding. This block of code should 'never' happen. Anyway I do not think it has something to do with incoming message acknowledging. There might be something wrong...

Regarding the memory limit, I encountered the error while using default settings and a basic relay function. By sending several thousand messages of approximately 30KB each to a Pulsar topic,...

@ozangunalp thanks a lot for your input. Here are my thoughts on this The bottleneck arises when setting `maxPendingMessages` for partitioned topics. When `maxPendingMessages` is configured, SmallRye applies backpressure, preventing...

I believe separating the backpressure configuration from the producer configuration is a beneficial approach. This way, the default mechanism can rely on SmallRye configuration, allowing producers to operate without limitations...