Slackbot
02/14/2023, 6:03 PMbala rao
02/14/2023, 6:08 PMbala rao
02/14/2023, 6:08 PMKey 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.bala rao
02/14/2023, 6:10 PMbala rao
02/14/2023, 6:11 PMIgor Morozov
02/14/2023, 6:17 PMbala rao
02/14/2023, 7:00 PMPenghui
02/15/2023, 7:41 AMIgor Morozov
02/15/2023, 7:46 AMThere is no difference between partitioned topics and normal topics in terms of how subscription types work.This can lead to unexpected results... And if I'm not mistaken, adding more partitions to the existing topic will lead to having messages with the same key in different partitions at the same time
Penghui
02/16/2023, 11:48 AM