fix(otel): restore normal Kafka relationships on staging (#2595)

* fix: Moved back normal rels for Otel kafka

* fix: Test fix

Author: shashank-reddy-nr

relationships/synthesis/INFRA-HOST-to-INFRA-KAFKABROKER.stg.yml

@@ -160,15 +160,26 @@ relationships:
         present: true
       - attribute: broker.endpoint
         regex: ".*(localhost|127\\.0\\.0\\.1|::1|0\\.0\\.0\\.0).*"
+      - attribute: entity.type
+        anyOf: [ "KAFKABROKER" ]
+      - attribute: k8s.pod.name # condition to exclude k8s pod based hosts
+        present: false
     relationship:
       expires: PT75M
       relationshipType: HOSTS
       source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
+        buildGuid:
+          account:
+            attribute: accountId
+          domain:
+            value: INFRA
+          type:
+            value: HOST
+            valueInGuid: NA
+          identifier:
+            fragments:
+              - attribute: host.id
+            hashAlgorithm: FARM_HASH
       target:
         extractGuid:
           attribute: entity.guid
@@ -191,15 +202,26 @@ relationships:
         present: true
       - attribute: broker.endpoint
         regex: "^(?!.*(localhost|127\\.0\\.0\\.1|::1|0\\.0\\.0\\.0)).*$"
+      - attribute: entity.type
+        anyOf: [ "KAFKABROKER" ]
+      - attribute: k8s.pod.name # condition to exclude k8s pod based hosts
+        present: false
     relationship:
       expires: PT75M
       relationshipType: MEASURES
       source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
+        buildGuid:
+          account:
+            attribute: accountId
+          domain:
+            value: INFRA
+          type:
+            value: HOST
+            valueInGuid: NA
+          identifier:
+            fragments:
+              - attribute: host.id
+            hashAlgorithm: FARM_HASH
       target:
         extractGuid:
           attribute: entity.guid
@@ -220,106 +242,26 @@ relationships:
         present: true
       - attribute: broker.endpoint
         present: false
-    relationship:
-      expires: PT75M
-      relationshipType: MEASURES
-      source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
-      target:
-        extractGuid:
-          attribute: entity.guid
-          entityType:
-            value: KAFKABROKER
-
-  # Remote scenario: Host monitors remote Kafka broker with OpenTelemetry when broker.endpoint is present
-  - name: hostMonitorsOtelKafkaBrokerRemote
-    version: "1"
-    origins:
-      - OpenTelemetry
-    conditions:
-      - attribute: eventType
-        anyOf: [ "Metric" ]
-      - attribute: instrumentation.provider
-        anyOf: [ "opentelemetry" ]
-      - attribute: host.id
-        present: true
-      - attribute: broker.endpoint
-        present: true
-      - attribute: broker.endpoint
-        regex: "^(?!.*(localhost|127\\.0\\.0\\.1|::1|0\\.0\\.0\\.0)).*$"
-    relationship:
-      expires: PT75M
-      relationshipType: MEASURES
-      source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
-      target:
-        extractGuid:
-          attribute: entity.guid
-          entityType:
-            value: KAFKABROKER
-
-  # Host measures Kafka broker with OpenTelemetry when broker.endpoint is not present
-  - name: hostMonitorsOtelKafkaBrokerNoEndpoint
-    version: "1"
-    origins:
-      - OpenTelemetry
-    conditions:
-      - attribute: eventType
-        anyOf: [ "Metric" ]
-      - attribute: instrumentation.provider
-        anyOf: [ "opentelemetry" ]
-      - attribute: host.id
-        present: true
-      - attribute: broker.endpoint
+      - attribute: entity.type
+        anyOf: [ "KAFKABROKER" ]
+      - attribute: k8s.pod.name # condition to exclude k8s pod based hosts
         present: false
     relationship:
       expires: PT75M
       relationshipType: MEASURES
       source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
-      target:
-        extractGuid:
-          attribute: entity.guid
-          entityType:
-            value: KAFKABROKER
-
-  # Local scenario: Kafka broker running on the same host with OpenTelemetry
-  - name: hostHostsOtelKafkaBrokerLocalhost
-    version: "1"
-    origins:
-      - OpenTelemetry
-    conditions:
-      - attribute: eventType
-        anyOf: [ "Metric" ]
-      - attribute: instrumentation.provider
-        anyOf: [ "opentelemetry" ]
-      - attribute: host.id
-        present: true
-      - attribute: broker.endpoint
-        present: true
-      - attribute: broker.endpoint
-        regex: ".*(localhost|127\\.0\\.0\\.1|::1|0\\.0\\.0\\.0).*"
-    relationship:
-      expires: PT75M
-      relationshipType: HOSTS
-      source:
-        lookupGuid:
-          candidateCategory: HOST
-          fields:
-            - field: hostId
-              attribute: host.id
+        buildGuid:
+          account:
+            attribute: accountId
+          domain:
+            value: INFRA
+          type:
+            value: HOST
+            valueInGuid: NA
+          identifier:
+            fragments:
+              - attribute: host.id
+            hashAlgorithm: FARM_HASH
       target:
         extractGuid:
           attribute: entity.guid