Update ingesters to all use Failover subscription mode (#3873)

The scheduler ingester already uses Failover, swapping all to Failover so we are consistent This will also allow us to get good latency metrics of processing delay by partition from pulsar: - When we use KeyShared, we may not process a partition strictly in order, so the metric isn't that useful Signed-off-by: JamesMurkin <[email protected]>
armadaproject · Aug 13, 2024 · b8fdf3d · b8fdf3d
1 parent fcf7fe6
commit b8fdf3d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -60,7 +60,7 @@ func Run(config *configuration.LookoutIngesterV2Configuration) {
 		config.SubscriptionName,
 		config.BatchSize,
 		config.BatchDuration,
-		pulsar.KeyShared,
+		pulsar.Failover,
 		converter,
 		lookoutDb,
 		config.MetricsPort,