Fix drop tracking of aggregator drop_original metrics (#5632)

This commit is contained in:
John Hu 2019-03-27 09:01:50 +08:00 committed by Daniel Nelson
parent 0f21373439
commit 5e6374c19b
2 changed files with 4 additions and 2 deletions

View File

@ -364,6 +364,8 @@ func (a *Agent) runAggregators(
if !dropOriginal {
dst <- metric
} else {
metric.Drop()
}
}
cancel()

View File

@ -17,7 +17,7 @@ services:
- KAFKA_ADVERTISED_HOST_NAME=localhost
- KAFKA_ADVERTISED_PORT=9092
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_CREATE_TOPICS="test:1:1"
- KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
- JAVA_OPTS="-Xms256m -Xmx256m"
ports:
- "9092:9092"