From 24c422ac4c2c9b4b805d6e793af39278234b0802 Mon Sep 17 00:00:00 2001 From: Samuel Attwood Date: Mon, 13 Jan 2025 05:27:21 -0500 Subject: [PATCH] Add check for removed Push Consumer options --- internal/controller/consumer_controller.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/controller/consumer_controller.go b/internal/controller/consumer_controller.go index 69ad4a02..a7118735 100644 --- a/internal/controller/consumer_controller.go +++ b/internal/controller/consumer_controller.go @@ -118,6 +118,11 @@ func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c return ctrl.Result{}, nil } + if consumer.Spec.FlowControl || consumer.Spec.DeliverSubject != "" || consumer.Spec.DeliverGroup != "" || consumer.Spec.HeartbeatInterval != "" { + log.Info("FlowControl, DeliverSubject, DeliverGroup, and HeartbeatInterval are Push Consumer options, which are no longer supported. Skipping consumer creation or update.") + return ctrl.Result{}, nil + } + // Create or update stream if err := r.createOrUpdate(ctx, log, consumer); err != nil { return ctrl.Result{}, fmt.Errorf("create or update: %s", err)