Skip to content

Commit eac4c92

Browse files
committed
Activate dynamic batching by default
References rabbitmq/rabbitmq-stream-java-client#671
1 parent 04124ff commit eac4c92

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

Diff for: pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
</scm>
4646

4747
<properties>
48-
<stream-client.version>0.20.0</stream-client.version>
48+
<stream-client.version>0.21.0-SNAPSHOT</stream-client.version>
4949
<slf4j.version>2.0.16</slf4j.version>
5050
<logback.version>1.5.12</logback.version>
5151
<netty.version>4.1.115.Final</netty.version>

Diff for: src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -458,7 +458,7 @@ public class StreamPerfTest implements Callable<Integer> {
458458
@CommandLine.Option(
459459
names = {"--dynamic-batch-size", "-dbs"},
460460
description = "use dynamic batch size for publishing",
461-
defaultValue = "false")
461+
defaultValue = "true")
462462
private boolean dynamicBatch;
463463

464464
@CommandLine.Option(
@@ -504,7 +504,7 @@ static class InstanceSyncOptions {
504504
@CommandLine.Option(
505505
names = {"--initial-credits", "-ic"},
506506
description = "initial credits for subscription",
507-
defaultValue = "1",
507+
defaultValue = "10",
508508
converter = Utils.NotNegativeIntegerTypeConverter.class)
509509
private int initialCredits;
510510

0 commit comments

Comments
 (0)