File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/test/java/com/rabbitmq/stream/perf Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -313,15 +313,15 @@ void streamCreationIsIdempotentWhateverTheDifferencesInStreamProperties() throws
313
313
new StreamParametersBuilder ()
314
314
.maxLengthBytes (ByteCapacity .GB (1 ))
315
315
.maxSegmentSizeBytes (ByteCapacity .MB (500 ))
316
- .leaderLocator (LeaderLocator .LEAST_LEADERS )
316
+ .leaderLocator (LeaderLocator .BALANCED )
317
317
.build ());
318
318
assertThat (response .isOk ()).isTrue ();
319
319
Future <?> run =
320
320
run (
321
321
builder ()
322
322
.maxLengthBytes (ByteCapacity .GB (42 )) // different from already existing stream
323
323
.streamMaxSegmentSizeBytes (ByteCapacity .MB (500 ))
324
- .leaderLocator (LeaderLocator .LEAST_LEADERS ));
324
+ .leaderLocator (LeaderLocator .BALANCED ));
325
325
waitOneSecond ();
326
326
run .cancel (true );
327
327
waitRunEnds ();
You can’t perform that action at this time.
0 commit comments