Create eventtypes on reply events to triggers and subscriptions #8671
Annotations
2 errors and 1 warning
control-plane/pkg/reconciler/sink/kafka_sink.go#L1
Please run goimports.
diff --git a/control-plane/pkg/reconciler/sink/kafka_sink.go b/control-plane/pkg/reconciler/sink/kafka_sink.go
index 9b4fea2..37d1b9d 100644
--- a/control-plane/pkg/reconciler/sink/kafka_sink.go
+++ b/control-plane/pkg/reconciler/sink/kafka_sink.go
@@ -437,8 +437,8 @@ func (r *Reconciler) getSinkContractResource(ctx context.Context, kafkaSink *eve
Uid: string(kafkaSink.UID),
Topics: []string{kafkaSink.Spec.Topic},
Ingress: &contract.Ingress{
- Path: receiver.PathFromObject(kafkaSink),
- ContentMode: coreconfig.ContentModeFromString(*kafkaSink.Spec.ContentMode),
+ Path: receiver.PathFromObject(kafkaSink),
+ ContentMode: coreconfig.ContentModeFromString(*kafkaSink.Spec.ContentMode),
},
FeatureFlags: &contract.FeatureFlags{
EnableEventTypeAutocreate: features.IsEnabled(feature.EvenTypeAutoCreate),
|
|
|
This job failed
Loading