diff --git a/tests/e2e/test_online_features.py b/tests/e2e/test_online_features.py
index e038936da88..6c2df4391a1 100644
--- a/tests/e2e/test_online_features.py
+++ b/tests/e2e/test_online_features.py
@@ -134,7 +134,7 @@ def test_streaming_ingestion(
         job = None
 
     wait_retry_backoff(
-        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120
+        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300
     )
 
     test_data = generate_data()[["s2id", "unique_drivers", "event_timestamp"]]
diff --git a/tests/e2e/test_validation.py b/tests/e2e/test_validation.py
index 276d1126f6b..dcb7ac8a1eb 100644
--- a/tests/e2e/test_validation.py
+++ b/tests/e2e/test_validation.py
@@ -103,7 +103,7 @@ def test_validation_with_ge(feast_client: Client, kafka_server, pytestconfig):
     job = start_job(feast_client, feature_table, pytestconfig)
 
     wait_retry_backoff(
-        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120
+        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300
     )
 
     test_data = generate_test_data()
@@ -170,7 +170,7 @@ def test_validation_reports_metrics(
     job = start_job(feast_client, feature_table, pytestconfig)
 
     wait_retry_backoff(
-        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120
+        lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300
     )
 
     test_data = generate_test_data()