From b289ddd47f8c8370dcd2be43c81777228e652585 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nicol=C3=B2=20Boschi?= <boschi1997@gmail.com>
Date: Mon, 20 May 2024 14:04:39 +0200
Subject: [PATCH] fix

---
 .../ai/langstream/apigateway/http/GatewayResourceTest.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java b/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java
index 5bb3f8e81..7d1e83344 100644
--- a/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java
+++ b/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java
@@ -569,8 +569,11 @@ void testService() throws Exception {
                         url,
                         "{\"key\": \"my-key2\", \"value\": \"my-value\", \"headers\": {\"header1\":\"value1\"}}"));
 
+        // sorry but kafka can't keep up
+        final int numParallel = getStreamingCluster().type().equals("kafka") ? 5 : 30;
+
         List<CompletableFuture<Void>> futures1 = new ArrayList<>();
-        for (int i = 0; i < 30; i++) {
+        for (int i = 0; i < numParallel; i++) {
             CompletableFuture<Void> future =
                     CompletableFuture.runAsync(
                             () -> {