From 53df13431da5dde7bfa6ac04f73d601a3836c52f Mon Sep 17 00:00:00 2001
From: John Hu <hszqqq12@gmail.com>
Date: Tue, 26 Mar 2019 18:23:22 +0800
Subject: [PATCH 1/2] Update docker-compose.yml

---
 docker-compose.yml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docker-compose.yml b/docker-compose.yml
index 5ac47089db975..ca5fa38366a5e 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

From 7a2a8663acaf77f398cb3ddcced70d976e9819f1 Mon Sep 17 00:00:00 2001
From: John Hu <hszqqq12@gmail.com>
Date: Tue, 26 Mar 2019 18:28:33 +0800
Subject: [PATCH 2/2] Add missing metric.Drop() call in runAggregators()

---
 agent/agent.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/agent/agent.go b/agent/agent.go
index d2bc69ad06052..d8374881186c5 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()