diff --git a/cmd/jaeger/integration/kafka_test.go b/cmd/jaeger/integration/kafka_test.go
index b348bce0aa1..514d66def0c 100644
--- a/cmd/jaeger/integration/kafka_test.go
+++ b/cmd/jaeger/integration/kafka_test.go
@@ -79,7 +79,7 @@ func TestKafkaStorage(t *testing.T) {
 		load := i == 0
 		if load {
 			tc.StartLoad(testbed.LoadOptions{
-				DataItemsPerSecond: 1024,
+				DataItemsPerSecond: 16,
 				ItemsPerBatch:      1,
 			})
 		}