Skip to content

fix: Fixed OTel kafka dashboard queries #2791

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rprakash93 merged 2 commits into from
Feb 19, 2026
Merged

fix: Fixed OTel kafka dashboard queries #2791

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1426666
fix: Fixed OTel kafka dashboard queries
shashank-reddy-nr Feb 18, 2026
661c71a
fix: Optimized OTel kafka dashboard queries
shashank-reddy-nr Feb 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 14 additions & 14 deletions dashboards/kafka-otel/kafka-otel.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -143,15 +143,15 @@
},
{
"accountIds": [],
"query": "SELECT sum(partitions) AS 'Offline partitions' FROM (SELECT latest(`kafka.partition.offline`) AS 'partitions' FROM Metric WHERE metricName='kafka.partition.offline' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(partitions) AS 'Offline partitions' FROM (SELECT latest(`kafka.partition.offline`) AS 'partitions' FROM Metric WHERE metricName='kafka.partition.offline' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": " SELECT sum(under_replicated_partitions) as 'Under-replicated partitions' FROM (SELECT latest(kafka.partition.under_replicated) as 'under_replicated_partitions' FROM Metric where metricName='kafka.partition.under_replicated' and kafka.cluster.name in ({{cluster}}) facet broker.id, kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": "SELECT sum(partitions) as 'Under min ISR partitions' FROM (SELECT max(kafka.partition.under_min_isr) AS 'partitions' FROM Metric WHERE metricName = 'kafka.partition.under_min_isr' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(partitions) as 'Under min ISR partitions' FROM (SELECT max(kafka.partition.under_min_isr) AS 'partitions' FROM Metric WHERE metricName = 'kafka.partition.under_min_isr' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
}
],
"thresholdsWithSeriesOverrides": {
Expand Down Expand Up @@ -201,23 +201,23 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": "SELECT sum(topics) as 'Total topics' FROM (SELECT latest(kafka.cluster.topic.count) AS 'topics' FROM Metric WHERE metricName='kafka.cluster.topic.count' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(topics) as 'Total topics' FROM (SELECT latest(kafka.cluster.topic.count) AS 'topics' FROM Metric WHERE metricName='kafka.cluster.topic.count' AND kafka.cluster.topic.count>0 AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": "SELECT sum(topics) as 'Active topics' FROM (SELECT uniqueCount(topic) AS 'topics' FROM Metric WHERE metricName='kafka.topic.partitions' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(active_topics) as 'Active Topics' FROM (SELECT uniqueCount(topic) as 'active_topics' FROM Metric WHERE metricName='kafka.topic.io' AND kafka.topic.io > 0 and kafka.cluster.name in ({{cluster}}) facet topic, kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": "SELECT sum(groups) AS 'Consumer groups' FROM (SELECT uniqueCount(group) as 'groups' FROM Metric WHERE metricName='kafka.consumer_group.members' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(groups) AS 'Consumer groups' FROM (SELECT uniqueCount(group) as 'groups' FROM Metric WHERE metricName='kafka.consumer_group.members' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT latest(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName = 'kafka.cluster.partition.count' AND kafka.cluster.partition.count>0 AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
},
{
"accountIds": [],
Expand Down Expand Up @@ -258,7 +258,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}}) facet kafka.cluster.name"
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX) facet kafka.cluster.name"
}
]
}
Expand All @@ -279,7 +279,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(topics) as 'Active topics' FROM (SELECT uniqueCount(topic) AS 'topics' FROM Metric WHERE metricName='kafka.topic.partitions' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}}) facet kafka.cluster.name"
"query": "SELECT sum(topics) as 'Active topics' FROM (SELECT uniqueCount(topic) AS 'topics' FROM Metric WHERE metricName='kafka.topic.partitions' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX) facet kafka.cluster.name"
}
]
}
Expand All @@ -300,7 +300,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}}) facet kafka.cluster.name"
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX) facet kafka.cluster.name"
}
]
}
Expand Down Expand Up @@ -987,7 +987,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(brokers) as 'Active brokers' FROM (SELECT latest(kafka.brokers) AS 'brokers' FROM Metric WHERE metricName='kafka.brokers' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
}
]
}
Expand All @@ -1014,7 +1014,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
}
]
}
Expand Down Expand Up @@ -1812,7 +1812,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(topics) as 'Active topics' FROM (SELECT uniqueCount(topic) AS 'topics' FROM Metric WHERE metricName='kafka.topic.partitions' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(active_topics) as 'Active Topics' FROM (SELECT uniqueCount(topic) as 'active_topics' FROM Metric WHERE metricName='kafka.topic.io' AND kafka.topic.io > 0 and kafka.cluster.name in ({{cluster}}) facet topic, kafka.cluster.name LIMIT MAX)"
}
]
}
Expand All @@ -1839,7 +1839,7 @@
"nrqlQueries": [
{
"accountIds": [],
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
"query": "SELECT sum(partitions) as 'Total partitions' FROM (SELECT max(kafka.cluster.partition.count) AS 'partitions' FROM Metric WHERE metricName='kafka.cluster.partition.count' AND kafka.cluster.name in ({{cluster}}) FACET kafka.cluster.name LIMIT MAX)"
}
]
}
Expand Down
Loading