Slackbot
05/04/2023, 3:20 PMAsaf Mesika
05/04/2023, 6:13 PMAleksey
05/05/2023, 7:41 AMAlvaro Rodriguez
05/05/2023, 10:26 AMstats
- https://pulsar.apache.org/docs/next/administration-stats/ and monitor the availablePermits
Aleksey
05/05/2023, 10:32 AMAsaf Mesika
05/05/2023, 11:24 AMAsaf Mesika
05/05/2023, 11:24 AMKey Shared Subscription type guarantees a key will be processed by a single consumer at any given time. When a new consumer is connected, some keys will change their mapping from existing consumers to the new consumer. Once the connection has been established, the broker will record the current read position and associate it with the new consumer. The read position is a marker indicating that messages have been dispatched to the consumers up to this point, and after it, no messages have been dispatched yet. The broker will start delivering messages to the new consumer only when all messages up to the read position have been acknowledged. This will guarantee that a certain key is processed by a single consumer at any given time. The trade-off is that if one of the existing consumers is stuck and no time-out was defined (acknowledging for you), the new consumer won’t receive any messages until the stuck consumer resumes or gets disconnected.
That requirement can be relaxed by enablingvia the Consumer API. If set on the new consumer, then when it is connected, the broker will allow it to receive messages knowing some messages of that key may be still be processing in other consumers at the time, thus order may be affected for that short period of adding a new consumer.allowOutOfOrderDelivery
Asaf Mesika
05/05/2023, 11:24 AMAleksey
05/05/2023, 11:52 AMAleksandr Nedorezov
05/05/2023, 1:21 PMMuni Chada
05/05/2023, 8:04 PM