diff --git a/test/http-stress/test-results.json b/test/http-stress/test-results.json
index e3053a69..2191acba 100644
--- a/test/http-stress/test-results.json
+++ b/test/http-stress/test-results.json
@@ -5,7 +5,7 @@
   "TestHTTPSinkStress/N=50000.tps": 1000,
   "TestHTTPSinkStress/messageSize=1000.tps": 450,
   "TestHTTPSinkStress/replicas=2.tps": 1150,
-  "TestHTTPSourceStress/.tps": 1450,
+  "TestHTTPSourceStress/.tps": 1150,
   "TestHTTPSourceStress/N=10,messageSize=100.tps": 0,
   "TestHTTPSourceStress/N=10,messageSize=1000.tps": 1050,
   "TestHTTPSourceStress/N=100000.tps": 1000,
diff --git a/test/kafka-stress/test-results.json b/test/kafka-stress/test-results.json
index b48a743b..dd19d435 100644
--- a/test/kafka-stress/test-results.json
+++ b/test/kafka-stress/test-results.json
@@ -1,12 +1,12 @@
 {
-  "TestKafkaSinkStress/.tps": 600,
+  "TestKafkaSinkStress/.tps": 750,
   "TestKafkaSinkStress/N=10,messageSize=100.tps": 200,
   "TestKafkaSinkStress/N=10,messageSize=1000.tps": 150,
   "TestKafkaSinkStress/N=50000.tps": 750,
   "TestKafkaSinkStress/async=true.tps": 400,
   "TestKafkaSinkStress/messageSize=1000.tps": 300,
   "TestKafkaSinkStress/replicas=2.tps": 400,
-  "TestKafkaSourceStress/.tps": 2900,
+  "TestKafkaSourceStress/.tps": 3450,
   "TestKafkaSourceStress/N=10,messageSize=100.tps": 450,
   "TestKafkaSourceStress/N=10,messageSize=1000.tps": 650,
   "TestKafkaSourceStress/N=50000.tps": 3150,