fix: kafka flaky batching test (#3447)

rudderlabs · Jun 6, 2023 · fcd49e4 · fcd49e4
1 parent fda4baf
commit fcd49e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/streammanager/kafka/kafkamanager_test.go b/services/streammanager/kafka/kafkamanager_test.go
@@ -318,7 +318,7 @@ func TestIntegration(t *testing.T) {
 				{"message":"three","topic":"foo-bar","userId":"1234"}
 			]`), destConfig)
 			return statusCode == http.StatusOK
-		}, 10*time.Second, 100*time.Millisecond)
+		}, 30*time.Second, 100*time.Millisecond)
 		require.Equal(t, "Kafka: Message delivered in batch", returnMessage)
 		require.Equal(t, "Kafka: Message delivered in batch", errMessage)