debugging kafka e2e

Signed-off-by: MenD32 <amit@jounce.io>
argoproj · Aug 24, 2024 · c5566d9 · c5566d9
1 parent dd9c09b
commit c5566d9
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/controllers/eventsource/resource.go b/controllers/eventsource/resource.go
@@ -389,9 +389,11 @@ func buildService(args *AdaptorArgs) (*corev1.Service, error) {
 
 	if args.EventSource.Spec.Service.Metadata != nil {
 		annotations = args.EventSource.Spec.Service.Metadata.Annotations
-		labels = mergeLabels(args.EventSource.Spec.Service.Metadata.Labels, args.EventSource.Labels)
+		// labels = mergeLabels(args.EventSource.Spec.Service.Metadata.Labels, args.EventSource.Labels)
 	}
 
+	fmt.Printf("%+v %+v\n", annotations, labels)
+
 	svc := &corev1.Service{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      fmt.Sprintf("%s-eventsource-svc", eventSource.Name),
@@ -405,8 +407,8 @@ func buildService(args *AdaptorArgs) (*corev1.Service, error) {
 			Selector:  args.Labels,
 		},
 	}
-	svc.ObjectMeta.SetAnnotations(annotations)
-	svc.ObjectMeta.SetLabels(labels)
+	// svc.ObjectMeta.SetAnnotations(annotations)
+	// svc.ObjectMeta.SetLabels(labels)
 	if err := controllerscommon.SetObjectMeta(eventSource, svc, v1alpha1.SchemaGroupVersionKind); err != nil {
 		return nil, err
 	}

diff --git a/examples/event-sources/webhook.yaml b/examples/event-sources/webhook.yaml
@@ -7,6 +7,11 @@ spec:
     ports:
       - port: 12000
         targetPort: 12000
+    metadata:
+      labels:
+        foo: bar
+      annotations:
+        foo: bar
   webhook:
     # event-source can run multiple HTTP servers. Simply define a unique port to start a new HTTP server
     example: