This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 9c7716ce12b [improve][client] Mention partitioning in failover
priorityLevel javaDoc (#21980)
9c7716ce12b is described below
commit 9c7716ce12b1905cbe4c95fb87a623c70b694085
Author: Matt Whipple <[email protected]>
AuthorDate: Mon Feb 5 07:28:31 2024 -0500
[improve][client] Mention partitioning in failover priorityLevel javaDoc
(#21980)
Co-authored-by: Matteo Merli <[email protected]>
---
.../main/java/org/apache/pulsar/client/api/ConsumerBuilder.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
index f37aa5028eb..6a9aee63fce 100644
---
a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
+++
b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
@@ -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
@@ -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
*/