diff --git a/internal/eventingester/ingester.go b/internal/eventingester/ingester.go
index db5a402a7c6..d2fe2f8d09d 100644
--- a/internal/eventingester/ingester.go
+++ b/internal/eventingester/ingester.go
@@ -64,7 +64,7 @@ func Run(config *configuration.EventIngesterConfiguration) {
 		config.SubscriptionName,
 		config.BatchSize,
 		config.BatchDuration,
-		pulsar.KeyShared,
+		pulsar.Failover,
 		converter,
 		eventDb,
 		config.MetricsPort,
diff --git a/internal/lookoutingesterv2/ingester.go b/internal/lookoutingesterv2/ingester.go
index 2df02f2301c..3d02c6148d0 100644
--- a/internal/lookoutingesterv2/ingester.go
+++ b/internal/lookoutingesterv2/ingester.go
@@ -60,7 +60,7 @@ func Run(config *configuration.LookoutIngesterV2Configuration) {
 		config.SubscriptionName,
 		config.BatchSize,
 		config.BatchDuration,
-		pulsar.KeyShared,
+		pulsar.Failover,
 		converter,
 		lookoutDb,
 		config.MetricsPort,