I’m trying to graph consumer lag by service (Which maps to consumer group) to track what my total consumer lag is over a particular topic for a given consumer group. I can get an individual Partition avg over time with this:
SELECT average(consumer-fetch-manager-metrics.audit-0.records-lag
) FROM KafkaMetrics FACET host SINCE 7 DAYS AGO WHERE appName = ‘audit-service’ TIMESERIES
But the topic has 32 partitions, and I want to summarize them all without having to add every single partition to the query. Is there a way to combine elements with something like consumer-fetch-manager-metrics.audit-*.records-lag ??