Merge pull request #431 from DataDog/kravishankar/STREAMS-2057-fix

[Metricsfetcher] Change broker query to use last instead of rollup
DataDog · Oct 3, 2023 · b298cd9 · b298cd9
2 parents 3f44cc1 + 82e2a9c
commit b298cd9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/metricsfetcher/main.go b/cmd/metricsfetcher/main.go
@@ -61,7 +61,7 @@ func init() {
 	}
 
 	// Complete query string.
-	config.BrokerQuery = fmt.Sprintf("%s by {%s}.rollup(avg, %d)", *bq, config.BrokerIDTag, config.Span)
+	config.BrokerQuery = fmt.Sprintf("%s by {%s}.fill(last)", *bq, config.BrokerIDTag)
 	config.PartnQuery = fmt.Sprintf("%s.rollup(avg, %d)", *pq, config.Span)
 }