Skip to content

Commit c1bedef

Browse files
authored
Merge pull request #236 from rabbitmq/leader-locator-balanced
Use "balanced" for leader locator default value
2 parents e630836 + 00eff33 commit c1bedef

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ void setDeleteStreams(String input) throws Exception {
260260
"leader locator strategy for created stream. "
261261
+ "Possible values: client-local, balanced (RabbitMQ 3.10), least-leaders, random.",
262262
converter = Converters.LeaderLocatorTypeConverter.class,
263-
defaultValue = "least-leaders")
263+
defaultValue = "balanced")
264264
private LeaderLocator leaderLocator;
265265

266266
@CommandLine.Option(

src/test/java/com/rabbitmq/stream/perf/StreamPerfTestTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -313,15 +313,15 @@ void streamCreationIsIdempotentWhateverTheDifferencesInStreamProperties() throws
313313
new StreamParametersBuilder()
314314
.maxLengthBytes(ByteCapacity.GB(1))
315315
.maxSegmentSizeBytes(ByteCapacity.MB(500))
316-
.leaderLocator(LeaderLocator.LEAST_LEADERS)
316+
.leaderLocator(LeaderLocator.BALANCED)
317317
.build());
318318
assertThat(response.isOk()).isTrue();
319319
Future<?> run =
320320
run(
321321
builder()
322322
.maxLengthBytes(ByteCapacity.GB(42)) // different from already existing stream
323323
.streamMaxSegmentSizeBytes(ByteCapacity.MB(500))
324-
.leaderLocator(LeaderLocator.LEAST_LEADERS));
324+
.leaderLocator(LeaderLocator.BALANCED));
325325
waitOneSecond();
326326
run.cancel(true);
327327
waitRunEnds();

0 commit comments

Comments
 (0)