Apply topic filter to partitions metrics in burrow input (#6070)

(cherry picked from commit 04937d0498)
This commit is contained in:
Alvaro Olmedo Rodriguez
2019-07-09 10:54:01 -07:00
committed by Daniel Nelson
parent cb664a41ec
commit ba32cf477d
2 changed files with 4 additions and 1 deletions
+3
View File
@@ -432,6 +432,9 @@ func (b *burrow) genGroupStatusMetrics(r *apiResponse, cluster, group string, ac
func (b *burrow) genGroupLagMetrics(r *apiResponse, cluster, group string, acc telegraf.Accumulator) {
for _, partition := range r.Status.Partitions {
if !b.filterTopics.Match(partition.Topic) {
continue
}
acc.AddFields(
"burrow_partition",
map[string]interface{}{
+1 -1
View File
@@ -262,7 +262,7 @@ func TestFilterGroups(t *testing.T) {
acc := &testutil.Accumulator{}
plugin.Gather(acc)
require.Exactly(t, 4, len(acc.Metrics))
require.Exactly(t, 1, len(acc.Metrics))
require.Empty(t, acc.Errors)
}