diff --git a/services/streammanager/kafka/kafkamanager_test.go b/services/streammanager/kafka/kafkamanager_test.go
index fdcc7d1de2..35f2c1cc33 100644
--- 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)