fix(operator): make broker consumers listening broker (formancehq#1461)

personal-forks · Apr 26, 2024 · 1d95d58 · 1d95d58
1 parent 99de15d
commit 1d95d58
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/components/operator/internal/resources/brokerconsumers/init.go b/components/operator/internal/resources/brokerconsumers/init.go
@@ -3,6 +3,7 @@ package brokerconsumers
 import (
 	"github.com/formancehq/operator/api/formance.com/v1beta1"
 	"github.com/formancehq/operator/internal/core"
+	"github.com/formancehq/operator/internal/resources/brokers"
 	v1 "k8s.io/api/batch/v1"
 	"sigs.k8s.io/controller-runtime/pkg/builder"
 )
@@ -12,6 +13,7 @@ func init() {
 		core.WithStackDependencyReconciler(Reconcile,
 			core.WithOwn[*v1beta1.BrokerConsumer](&v1beta1.BrokerTopic{}, builder.MatchEveryOwner),
 			core.WithOwn[*v1beta1.BrokerConsumer](&v1.Job{}),
+			brokers.Watch[*v1beta1.BrokerConsumer](),
 		),
 	)
 }