From 5e6374c19b8d9c44258e444ad04e7f4670f8e8b9 Mon Sep 17 00:00:00 2001
From: John Hu <hszqqq12@gmail.com>
Date: Wed, 27 Mar 2019 09:01:50 +0800
Subject: [PATCH] Fix drop tracking of aggregator drop_original metrics (#5632)

---
 agent/agent.go     | 2 ++
 docker-compose.yml | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/agent/agent.go b/agent/agent.go
index d2bc69ad0..d83748811 100644
--- a/agent/agent.go
+++ b/agent/agent.go
@@ -364,6 +364,8 @@ func (a *Agent) runAggregators(
 
 			if !dropOriginal {
 				dst <- metric
+			} else {
+				metric.Drop()
 			}
 		}
 		cancel()
diff --git a/docker-compose.yml b/docker-compose.yml
index 5ac47089d..ca5fa3836 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -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"
@@ -38,7 +38,7 @@ services:
       - "3306:3306"
   memcached:
     image: memcached
-    ports: 
+    ports:
       - "11211:11211"
   pgbouncer:
     image: mbed/pgbouncer