diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go index d580fcaafe..a7fff84d7a 100644 --- a/control-plane/pkg/reconciler/trigger/controller.go +++ b/control-plane/pkg/reconciler/trigger/controller.go @@ -20,8 +20,6 @@ import ( "context" "knative.dev/eventing/pkg/auth" - - "github.com/IBM/sarama" "go.uber.org/zap" "k8s.io/apimachinery/pkg/labels" "k8s.io/client-go/tools/cache" @@ -100,8 +98,7 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf GetKafkaClient: clientPool.GetClient, GetKafkaClusterAdmin: clientPool.GetClusterAdmin, InitOffsetsFunc: offset.InitOffsets, - // ServiceAccountLister: serviceaccountInformer.Lister(), - serviceAccountLister: oidcServiceaccountInformer.Lister(), + ServiceAccountLister: oidcServiceaccountInformer.Lister(), } impl := triggerreconciler.NewImpl(ctx, reconciler, func(impl *controller.Impl) controller.Options { diff --git a/control-plane/pkg/reconciler/trigger/namespaced_controller_test.go b/control-plane/pkg/reconciler/trigger/namespaced_controller_test.go index 0524b3e03f..da77966b17 100644 --- a/control-plane/pkg/reconciler/trigger/namespaced_controller_test.go +++ b/control-plane/pkg/reconciler/trigger/namespaced_controller_test.go @@ -22,6 +22,8 @@ import ( corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "knative.dev/eventing/pkg/auth" + _ "knative.dev/pkg/client/injection/ducks/duck/v1/addressable/fake" _ "knative.dev/pkg/client/injection/kube/informers/core/v1/configmap/fake" _ "knative.dev/pkg/client/injection/kube/informers/core/v1/pod/fake"