Skip to content

Commit 486d542

Browse files
committed
Increase ingress rate in test
1 parent 1f25f73 commit 486d542

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/com/rabbitmq/stream/impl/SacClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -497,7 +497,7 @@ void superStreamRebalancingShouldWorkWhilePublishing(TestInfo info) throws Excep
497497
publisher.declarePublisher(b(0), null, partitionInUse);
498498
new Thread(
499499
() -> {
500-
long rate = 20_000;
500+
long rate = 50_000;
501501
Bucket bucket =
502502
Bucket.builder()
503503
.addLimit(limit -> limit.capacity(rate).refillGreedy(rate, ofSeconds(1)))

0 commit comments

Comments
 (0)