Use /lag instead of /status. Update tests.

influxdata · Nov 23, 2017 · 1a863dc · 1a863dc
1 parent c28689e
commit 1a863dc
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 1 deletion.
diff --git 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/..._clustername1_consumer_group1_status.json → ...fka_clustername1_consumer_group1_lag.json b/..._clustername1_consumer_group1_status.json → ...fka_clustername1_consumer_group1_lag.json
diff --git a/..._clustername1_consumer_group2_status.json → ...fka_clustername1_consumer_group2_lag.json b/..._clustername1_consumer_group2_status.json → ...fka_clustername1_consumer_group2_lag.json
diff --git a/..._clustername2_consumer_group3_status.json → ...fka_clustername2_consumer_group3_lag.json b/..._clustername2_consumer_group3_status.json → ...fka_clustername2_consumer_group3_lag.json