Skip to content

Commit

Permalink
Adding APM entity to ConfluentCloudKafkaTopic entity relationship
Browse files Browse the repository at this point in the history
  • Loading branch information
dsankaraganti committed Dec 26, 2024
1 parent ea4576f commit 65c00e3
Show file tree
Hide file tree
Showing 2 changed files with 64 additions and 0 deletions.
18 changes: 18 additions & 0 deletions relationships/candidates/CONFLUENTCLOUDKAFKATOPIC.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
category: CONFLUENTCLOUDKAFKATOPIC
lookups:
- entityTypes:
- domain: INFRA
type: CONFLUENTCLOUDKAFKATOPIC
tags:
matchingMode: ALL
predicates:
- tagKeys: ["bootstrap_servers"]
field: bootstrapServers
- tagKeys: ["confluent.kafka.server.metric.topic", "topic"]
field: topic
onMatch:
onMultipleMatches: RELATE_ALL
onMiss:
action: CREATE_UNINSTRUMENTED
uninstrumented:
type: KAFKATOPIC
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
relationships:
- name: apmProducesConfluentCloudKafkaTopic
version: "1"
origins:
- APM Metrics
conditions:
- attribute: metricName
regex: "^MessageBroker/Kafka/Nodes/([^.]*).([^.]*).([^.]*).confluent.cloud:9[0-9]+/Produce/.*"
relationship:
expires: P75M
relationshipType: PRODUCES
source:
extractGuid:
attribute: entity.guid
target:
lookupGuid:
candidateCategory: CONFLUENTCLOUDKAFKATOPIC
fields:
- field: bootstrapServers
capture:
attribute: metricName__4
- field: topic
attribute: metricName__6

- name: apmConsumesConfluentCloudKafkaTopic
version: "1"
origins:
- APM Metrics
conditions:
- attribute: metricName
regex: "^MessageBroker/Kafka/Nodes/([^.]*).([^.]*).([^.]*).confluent.cloud:9[0-9]+/Consume/.*"
relationship:
expires: P75M
relationshipType: CONSUMES
source:
extractGuid:
attribute: entity.guid
target:
lookupGuid:
candidateCategory: CONFLUENTCLOUDKAFKATOPIC
fields:
- field: bootstrapServers
capture:
attribute: metricName__4
- field: topic
attribute: metricName__6

0 comments on commit 65c00e3

Please sign in to comment.