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
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 ();
You can’t perform that action at this time.
0 commit comments