Skip to content

Commit 94e66ba

Browse files
committed
Two partitions consumed concurrently
1 parent 866e94e commit 94e66ba

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

ci/tests/run_perf_test.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,9 @@ async function main() {
5050
if (!process.env.CONSUMER_MAX_BATCH_SIZE) {
5151
process.env.CONSUMER_MAX_BATCH_SIZE = '-1';
5252
}
53+
if (!process.env.PARTITIONS_CONSUMED_CONCURRENTLY) {
54+
process.env.PARTITIONS_CONSUMED_CONCURRENTLY = '2';
55+
}
5356
const consumerMode = process.env.CONSUMER_MODE || 'all';
5457
const produceToSecondTopic = process.env.PRODUCE_TO_SECOND_TOPIC ? process.env.PRODUCE_TO_SECOND_TOPIC === 'true' : false;
5558
const produceToSecondTopicParam = produceToSecondTopic ? '--produce-to-second-topic' : '';

0 commit comments

Comments
 (0)