baomingyu opened a new issue #10284:
URL: https://github.com/apache/pulsar/issues/10284
In such scene , consumer will be stucked after restart.
First step ， tow consumers with key_shared subscription type and same group.
such as consumer1 and consumer2
Second step, broker receive consumer1 flow command with 1000 permits and do
not get consumer2's flow command.
Third step, broker start send message to consumer, but messages whit keys
are assigned to consumer2, so it will not send any message to consumers;
Fourth step , Next loop send time, getRestrictedMaxEntriesForConsumer will
aways return 0, and will not send any messages.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
