feat: Adding tags for confluent kafka topic

newrelic · Jan 8, 2025 · fc10a60 · fc10a60
1 parent 5e8be02
commit fc10a60
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/entity-types/infra-confluentcloudkafkatopic/definition.yml b/entity-types/infra-confluentcloudkafkatopic/definition.yml
@@ -7,11 +7,11 @@ goldenTags:
   - confluent.kafka.server.metric.topic
   - confluent.clusterId
   - confluent.metricNamespace
+  - confluent.clusterBootstrapServers
   - collector.name
   - instrumentation.provider
   - newrelic.source
   - kafka.cluster_name
-  - confluent.resourceType
   - collector.version
   - confluent.region
   - confluent.resourceGroup
@@ -47,6 +47,7 @@ synthesis:
       kafka_id:
       kafka.cluster_name:
       instrumentation.provider:
+      bootstrap.servers:
       newrelic.source:
     conditions:
       - attribute: eventType
@@ -73,6 +74,7 @@ synthesis:
       kafka_id:
       kafka.cluster_name:
       instrumentation.provider:
+      bootstrap.servers:
       newrelic.source:
     conditions:
       - attribute: eventType
@@ -100,6 +102,7 @@ synthesis:
       confluent.clusterId:
       confluent.clusterName:
       collector.name:
+      confluent.clusterBootstrapServers:
       confluent.metricNamespace:
       instrumentation.provider:
       newrelic.source:
@@ -133,6 +136,7 @@ synthesis:
       confluent.clusterName:
       collector.name:
       confluent.metricNamespace:
+      confluent.clusterBootstrapServers:
       instrumentation.provider:
       newrelic.source:
     conditions:

diff --git a/relationships/candidates/KAFKATOPIC.yml b/relationships/candidates/KAFKATOPIC.yml
@@ -25,7 +25,7 @@ lookups:
     tags:
       matchingMode: ALL
       predicates:
-        - tagKeys: ["bootstrap_servers"]
+        - tagKeys: ["confluent.clusterBootstrapServers", "bootstrap.servers"]
           field: bootstrapServers
         - tagKeys: ["confluent.kafka.server.metric.topic", "topic"]
           field: topic