From 99e1fb66255a5bc5ff2c0601ce3fe3d92452f6cf Mon Sep 17 00:00:00 2001 From: Simon Ehrenstein <simon.ehrenstein@gmail.com> Date: Fri, 18 Feb 2022 13:38:32 +0100 Subject: [PATCH] Change slo consumer lag metric --- .../src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt b/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt index 425a4f3b0..10d8df74c 100644 --- a/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt +++ b/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt @@ -4,7 +4,7 @@ import theodolite.benchmark.BenchmarkExecution import theodolite.util.InvalidPatcherConfigurationException import javax.enterprise.context.ApplicationScoped -private const val CONSUMER_LAG_QUERY = "sum by(group)(kafka_consumergroup_group_lag >= 0)" +private const val CONSUMER_LAG_QUERY = "sum by(group) (kafka_consumergroup_lag >= 0)" private const val DROPPED_RECORDS_QUERY = "sum by(job) (kafka_streams_stream_task_metrics_dropped_records_total>=0)" @ApplicationScoped -- GitLab