KafkaChannel hack

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
slinkydeveloper · Mar 17, 2021 · 11bfab0 · 11bfab0
1 parent b2ea385
commit 11bfab0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/reconciler/subscription/subscription.go b/pkg/reconciler/subscription/subscription.go
@@ -321,6 +321,12 @@ func (r *Reconciler) trackAndFetchChannel(ctx context.Context, sub *v1.Subscript
 func (r *Reconciler) getChannel(ctx context.Context, sub *v1.Subscription) (*eventingduckv1.Channelable, pkgreconciler.Event) {
 	logging.FromContext(ctx).Infow("Getting channel", zap.Any("channel", sub.Spec.Channel))
 
+	// HACK if a channel ref is a kafka channel ref, we need to hack it around to use only v1beta1
+	//  TODO REMOVE AFTER 0.22 release
+	if sub.Spec.Channel.Kind == "KafkaChannel" && sub.Spec.Channel.APIVersion == "messaging.knative.dev/v1alpha1" {
+		sub.Spec.Channel.APIVersion = "messaging.knative.dev/v1beta1"
+	}
+
 	// 1. Track the channel pointed by subscription.
 	//   a. If channel is a Channel.messaging.knative.dev
 	obj, err := r.trackAndFetchChannel(ctx, sub, sub.Spec.Channel)