Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

Commit

Permalink
[improve][client] Mention partitioning in failover priorityLevel java…
Browse files Browse the repository at this point in the history
…Doc (apache#21980)

Co-authored-by: Matteo Merli <mmerli@apache.org>
  • Loading branch information
mwhipple and merlimat authored Feb 5, 2024
1 parent 5dfdcb7 commit 9c7716c
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -511,9 +511,9 @@ public interface ConsumerBuilder<T> extends Cloneable {
* Order in which broker dispatches messages to consumers: C1, C2, C3, C1, C4, C5, C4
* </pre>
*
* <p><b>Failover subscription</b>
* The broker selects the active consumer for a failover subscription based on consumer's priority-level and
* lexicographical sorting of consumer name.
* <p><b>Failover subscription for partitioned topic</b>
* The broker selects the active consumer for a failover subscription for a partitioned topic
* based on consumer's priority-level and lexicographical sorting of consumer name.
* eg:
* <pre>
* 1. Active consumer = C1 : Same priority-level and lexicographical sorting
Expand All @@ -530,6 +530,8 @@ public interface ConsumerBuilder<T> extends Cloneable {
* Broker evenly assigns partitioned topics to highest priority consumers.
* </pre>
*
* <p>Priority level has no effect on failover subscriptions for non-partitioned topics.
*
* @param priorityLevel the priority of this consumer
* @return the consumer builder instance
*/
Expand Down

0 comments on commit 9c7716c

Please sign in to comment.