Skip to content

Commit 661c71a

Browse files
shashank-reddy-nrshashank-reddy-nr
committed
fix: Optimized OTel kafka dashboard queries
1 parent 1426666 commit 661c71a

File tree

1 file changed

+14
-14
lines changed

1 file changed

+14
-14
lines changed

‎dashboards/kafka-otel/kafka-otel.json‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -143,15 +143,15 @@
143143
},
144144
{
145145
"accountIds": [],
146-
"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}})"
146+
"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)"
147147
},
148148
{
149149
"accountIds": [],
150150
"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)"
151151
},
152152
{
153153
"accountIds": [],
154-
"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}})"
154+
"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)"
155155
}
156156
],
157157
"thresholdsWithSeriesOverrides": {
@@ -201,23 +201,23 @@
201201
"nrqlQueries": [
202202
{
203203
"accountIds": [],
204-
"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}})"
204+
"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)"
205205
},
206206
{
207207
"accountIds": [],
208-
"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 FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
208+
"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)"
209209
},
210210
{
211211
"accountIds": [],
212-
"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}})"
212+
"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)"
213213
},
214214
{
215215
"accountIds": [],
216-
"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}})"
216+
"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)"
217217
},
218218
{
219219
"accountIds": [],
220-
"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 FACET kafka.cluster.name LIMIT MAX) where kafka.cluster.name in ({{cluster}})"
220+
"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)"
221221
},
222222
{
223223
"accountIds": [],
@@ -258,7 +258,7 @@
258258
"nrqlQueries": [
259259
{
260260
"accountIds": [],
261-
"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"
261+
"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"
262262
}
263263
]
264264
}
@@ -279,7 +279,7 @@
279279
"nrqlQueries": [
280280
{
281281
"accountIds": [],
282-
"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"
282+
"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"
283283
}
284284
]
285285
}
@@ -300,7 +300,7 @@
300300
"nrqlQueries": [
301301
{
302302
"accountIds": [],
303-
"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"
303+
"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"
304304
}
305305
]
306306
}
@@ -987,7 +987,7 @@
987987
"nrqlQueries": [
988988
{
989989
"accountIds": [],
990-
"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}})"
990+
"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)"
991991
}
992992
]
993993
}
@@ -1014,7 +1014,7 @@
10141014
"nrqlQueries": [
10151015
{
10161016
"accountIds": [],
1017-
"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}})"
1017+
"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)"
10181018
}
10191019
]
10201020
}
@@ -1812,7 +1812,7 @@
18121812
"nrqlQueries": [
18131813
{
18141814
"accountIds": [],
1815-
"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}})"
1815+
"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)"
18161816
}
18171817
]
18181818
}
@@ -1839,7 +1839,7 @@
18391839
"nrqlQueries": [
18401840
{
18411841
"accountIds": [],
1842-
"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}})"
1842+
"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)"
18431843
}
18441844
]
18451845
}

0 commit comments

Comments
 (0)