Skip to content

Commit d978bde

Browse files
committed
Use least-leaders for default leader locator strategy
References rabbitmq/rabbitmq-server#4442. References #110
1 parent d38044a commit d978bde

File tree

3 files changed

+6
-2
lines changed

3 files changed

+6
-2
lines changed

src/main/java/com/rabbitmq/stream/StreamCreator.java

+4
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,8 @@ enum LeaderLocator {
8080
* overall less than 1000 queues, or a random node, if there are overall more than 1000 queues.
8181
*
8282
* <p>Available as of RabbitMQ 3.10.
83+
*
84+
* Default value for RabbitMQ 3.10+.
8385
*/
8486
BALANCED("balanced"),
8587

@@ -94,6 +96,8 @@ enum LeaderLocator {
9496
* The stream leader will be on the node with the least number of stream leaders.
9597
*
9698
* <p>Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}.
99+
*
100+
* Default value for RabbitMQ 3.9.
97101
*/
98102
LEAST_LEADERS("least-leaders");
99103

src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ class StreamStreamCreator implements StreamCreator {
2525

2626
private final StreamEnvironment environment;
2727
private final Client.StreamParametersBuilder streamParametersBuilder =
28-
new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.CLIENT_LOCAL);
28+
new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.LEAST_LEADERS);
2929
private String stream;
3030

3131
StreamStreamCreator(StreamEnvironment environment) {

src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,7 @@ public class StreamPerfTest implements Callable<Integer> {
241241
"leader locator strategy for created stream. "
242242
+ "Possible values: client-local, balanced (RabbitMQ 3.10), least-leaders, random.",
243243
converter = Utils.LeaderLocatorTypeConverter.class,
244-
defaultValue = "client-local")
244+
defaultValue = "least-leaders")
245245
private LeaderLocator leaderLocator;
246246

247247
@CommandLine.Option(

0 commit comments

Comments
 (0)