From 1a863dcc3a2c6e435be31a75f1bd51ec62fa6edb Mon Sep 17 00:00:00 2001 From: Arkady Emelyanov Date: Thu, 23 Nov 2017 18:32:08 +0300 Subject: [PATCH] Use /lag instead of /status. Update tests. --- plugins/inputs/burrow/burrow_consumer.go | 2 +- ...atus.json => v2_kafka_clustername1_consumer_group1_lag.json} | 0 ...atus.json => v2_kafka_clustername1_consumer_group2_lag.json} | 0 ...atus.json => v2_kafka_clustername2_consumer_group3_lag.json} | 0 4 files changed, 1 insertion(+), 1 deletion(-) rename plugins/inputs/burrow/testdata/{v2_kafka_clustername1_consumer_group1_status.json => v2_kafka_clustername1_consumer_group1_lag.json} (100%) rename plugins/inputs/burrow/testdata/{v2_kafka_clustername1_consumer_group2_status.json => v2_kafka_clustername1_consumer_group2_lag.json} (100%) rename plugins/inputs/burrow/testdata/{v2_kafka_clustername2_consumer_group3_status.json => v2_kafka_clustername2_consumer_group3_lag.json} (100%) diff --git a/plugins/inputs/burrow/burrow_consumer.go b/plugins/inputs/burrow/burrow_consumer.go index 7d0955455f420..25fd9fb6f64ff 100644 --- a/plugins/inputs/burrow/burrow_consumer.go +++ b/plugins/inputs/burrow/burrow_consumer.go @@ -44,7 +44,7 @@ func fetchConsumer(api apiClient, res apiResponse, uri string) { for _, group := range groupList { escaped := url.PathEscape(group) - producerChan <- fmt.Sprintf("%s/%s/status", uri, escaped) + producerChan <- fmt.Sprintf("%s/%s/lag", uri, escaped) } for i := len(groupList); i > 0; i-- { diff --git a/plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group1_status.json b/plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group1_lag.json similarity index 100% rename from plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group1_status.json rename to plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group1_lag.json diff --git a/plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group2_status.json b/plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group2_lag.json similarity index 100% rename from plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group2_status.json rename to plugins/inputs/burrow/testdata/v2_kafka_clustername1_consumer_group2_lag.json diff --git a/plugins/inputs/burrow/testdata/v2_kafka_clustername2_consumer_group3_status.json b/plugins/inputs/burrow/testdata/v2_kafka_clustername2_consumer_group3_lag.json similarity index 100% rename from plugins/inputs/burrow/testdata/v2_kafka_clustername2_consumer_group3_status.json rename to plugins/inputs/burrow/testdata/v2_kafka_clustername2_consumer_group3_lag.json