Please run goimports. diff --git a/control-plane/cmd/kafka-controller/main.go b/control-plane/cmd/kafka-controller/main.go index df4a3e7..0e2d833 100644 --- a/control-plane/cmd/kafka-controller/main.go +++ b/control-plane/cmd/kafka-controller/main.go @@ -75,10 +75,10 @@ func main() { ) if v := os.Getenv("ENABLE_SARAMA_LOGGER"); strings.EqualFold(v, "true") { - sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags | log.Llongfile) + sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags|log.Llongfile) } if v := os.Getenv("ENABLE_SARAMA_DEBUG_LOGGER"); strings.EqualFold(v, "true") { - sarama.DebugLogger = log.New(os.Stdout, "[sarama][debug] ", log.LstdFlags | log.Llongfile) + sarama.DebugLogger = log.New(os.Stdout, "[sarama][debug] ", log.LstdFlags|log.Llongfile) } if v := os.Getenv("ENABLE_SARAMA_CLIENT_POOL"); v == "" || strings.EqualFold(v, "true") { ctx = clientpool.WithKafkaClientPool(ctx)

Please run goimports. diff --git a/control-plane/pkg/reconciler/channel/controller.go b/control-plane/pkg/reconciler/channel/controller.go index d586eee..87d5c53 100644 --- a/control-plane/pkg/reconciler/channel/controller.go +++ b/control-plane/pkg/reconciler/channel/controller.go @@ -83,14 +83,14 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf DataPlaneNamespace: configs.SystemNamespace, ReceiverLabel: base.ChannelReceiverLabel, }, - Env: configs, - ConfigMapLister: configmapInformer.Lister(), - ServiceLister: serviceinformer.Get(ctx).Lister(), - SubscriptionLister: subscriptioninformer.Get(ctx).Lister(), - ConsumerGroupLister: consumerGroupInformer.Lister(), - EventPolicyLister: eventPolicyInformer.Lister(), - InternalsClient: consumergroupclient.Get(ctx), - KafkaFeatureFlags: apisconfig.DefaultFeaturesConfig(), + Env: configs, + ConfigMapLister: configmapInformer.Lister(), + ServiceLister: serviceinformer.Get(ctx).Lister(), + SubscriptionLister: subscriptioninformer.Get(ctx).Lister(), + ConsumerGroupLister: consumerGroupInformer.Lister(), + EventPolicyLister: eventPolicyInformer.Lister(), + InternalsClient: consumergroupclient.Get(ctx), + KafkaFeatureFlags: apisconfig.DefaultFeaturesConfig(), } clientPool := clientpool.Get(ctx)

Please run goimports. diff --git a/control-plane/pkg/reconciler/sink/controller.go b/control-plane/pkg/reconciler/sink/controller.go index 192ad38..0e41d5e 100644 --- a/control-plane/pkg/reconciler/sink/controller.go +++ b/control-plane/pkg/reconciler/sink/controller.go @@ -70,9 +70,9 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf DataPlaneNamespace: configs.SystemNamespace, ReceiverLabel: base.SinkReceiverLabel, }, - ConfigMapLister: configmapInformer.Lister(), - EventPolicyLister: eventPolicyInformer.Lister(), - Env: configs, + ConfigMapLister: configmapInformer.Lister(), + EventPolicyLister: eventPolicyInformer.Lister(), + Env: configs, } clientPool := clientpool.Get(ctx)

Process completed with exit code 1.