Hongten commented on code in PR #4604:
URL: https://github.com/apache/pulsar/pull/4604#discussion_r1115281052
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java:
##########
@@ -80,34 +80,45 @@ protected void notifyActiveConsumerChanged(Consumer
activeConsumer) {
}
/**
- * @return the previous active consumer if the consumer is changed,
otherwise null.
+ * Pick active consumer for a topic for {@link SubType#Failover}
subscription.
+ * If it's a non-partitioned topic then it'll pick consumer based on order
they subscribe to the topic.
+ * If is's a partitioned topic, first sort consumers based on their
priority level and consumer name then
+ * distributed partitions evenly across consumers with highest priority
level.
Review Comment:
I believe `the highest`
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
