fix

LangStream · May 20, 2024 · b289ddd · b289ddd
1 parent 5c1c8e2
commit b289ddd
Showing 1 changed file with 4 additions and 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
@@ -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(
                             () -> {