File tree Expand file tree Collapse file tree 2 files changed +2
-18
lines changed
src/main/java/com/rabbitmq/stream Expand file tree Collapse file tree 2 files changed +2
-18
lines changed Original file line number Diff line number Diff 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
Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments