Skip to content

Commit d61e6ea

Browse files
committed
Remove random and least-leaders leader locator strategy
Deprecated for several releases.
1 parent b885b89 commit d61e6ea

File tree

2 files changed

+2
-18
lines changed

2 files changed

+2
-18
lines changed

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

+1-17
Original file line numberDiff line numberDiff line change
@@ -146,23 +146,7 @@ enum LeaderLocator {
146146
*
147147
* <p>Default value for RabbitMQ 3.10+.
148148
*/
149-
BALANCED("balanced"),
150-
151-
/**
152-
* The stream leader will be a random node of the cluster.
153-
*
154-
* <p>Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}.
155-
*/
156-
RANDOM("random"),
157-
158-
/**
159-
* The stream leader will be on the node with the least number of stream leaders.
160-
*
161-
* <p>Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}.
162-
*
163-
* <p>Default value for RabbitMQ 3.9.
164-
*/
165-
LEAST_LEADERS("least-leaders");
149+
BALANCED("balanced");
166150

167151
String value;
168152

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

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

3333
private final StreamEnvironment environment;
3434
private final Client.StreamParametersBuilder streamParametersBuilder =
35-
new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.LEAST_LEADERS);
35+
new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.BALANCED);
3636
private String name;
3737
private DefaultSuperStreamConfiguration superStreamConfiguration;
3838

0 commit comments

Comments
 (0)