fix(kafka): remove mandatory key from custom

Author: nkmishra1997

DEPLOYMENT.md

@@ -319,3 +319,4 @@ This allows you to:
 - [ECS Task Definitions](https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task_definitions.html)
 - [GitHub Actions OIDC](https://docs.github.com/en/actions/deployment/security-hardening-your-deployments/configuring-openid-connect-in-amazon-web-services)
 
+

internal/custom-kafka-to-flexprice.yaml

@@ -39,8 +39,7 @@ pipeline:
           this.methodName != null && this.methodName != "" &&
           this.providerName != null && this.providerName != "" &&
           this.id != null && this.id != "" &&
-          this.startedAt != null && this.startedAt != "" &&
-          this.key != null && this.key != ""
+          this.startedAt != null && this.startedAt != ""
         )
 
         root = if $valid { this } else { deleted() }
@@ -52,7 +51,7 @@ pipeline:
         root.event_name = this.targetItemType.string() + "-" + this.methodName.string() + "-" + this.providerName.string()
         root.event_id = this.id.string()
         root.timestamp = this.startedAt.string()
-        root.source = this.key.string()
+        if this.targetItemId != null { root.source = this.targetItemId.string() }
 
         # Start with `data` fields (extract values from key-value objects, otherwise stringify)
         root.properties = if this.data != null && this.data.type() == "object" {