File tree 2 files changed +2
-18
lines changed
src/main/java/com/rabbitmq/stream
2 files changed +2
-18
lines changed Original file line number Diff line number Diff line change @@ -146,23 +146,7 @@ enum LeaderLocator {
146
146
*
147
147
* <p>Default value for RabbitMQ 3.10+.
148
148
*/
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" );
166
150
167
151
String value ;
168
152
Original file line number Diff line number Diff line change @@ -32,7 +32,7 @@ class StreamStreamCreator implements StreamCreator {
32
32
33
33
private final StreamEnvironment environment ;
34
34
private final Client .StreamParametersBuilder streamParametersBuilder =
35
- new Client .StreamParametersBuilder ().leaderLocator (LeaderLocator .LEAST_LEADERS );
35
+ new Client .StreamParametersBuilder ().leaderLocator (LeaderLocator .BALANCED );
36
36
private String name ;
37
37
private DefaultSuperStreamConfiguration superStreamConfiguration ;
38
38
You can’t perform that action at this time.
0 commit comments