fix config

VadimPlh · Sep 29, 2021 · 2af548d · 2af548d
1 parent 5f6d92e
commit 2af548d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/coproc-test/config.sh b/coproc-test/config.sh
@@ -1,8 +1,9 @@
 #!/bin/bash
 
 export COPROC_COUNT=5
-export RECORD_SIZE=1000
+export RECORD_SIZE=500
 export THROUGHPUT=-1
-export PARTITIONS=5
+export PARTITIONS=32
+export TIMEOUT=120000
 
-export MESSAGES_COUNT=100000
+export MESSAGES_COUNT=500000
diff --git a/coproc-test/test.sh b/coproc-test/test.sh
@@ -52,7 +52,7 @@ rm -rf ${CONSUMER_DIR}
 mkdir ${CONSUMER_DIR}
 for (( i=0; i < ${COPROC_COUNT}; i++ ))
 do
-    $consumer --topic "one_to_one_${i}."'$output$' --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094 --messages ${MESSAGES_COUNT} &> ${CONSUMER_DIR}/consumer_${i}.txt &
+    $consumer --topic "one_to_one_${i}."'$output$' --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094 --messages ${MESSAGES_COUNT} &> ${CONSUMER_DIR}/consumer_${i}.txt --timeout ${TIMEOUT} &
 done