fixup! WIP - Add Kinesis KCL Source

akka · Sep 27, 2017 · ee85afd · ee85afd
1 parent dfc3e20
commit ee85afd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kinesis/src/main/scala/akka/stream/alpakka/kinesis/KinesisWorkerSourceStage.scala b/kinesis/src/main/scala/akka/stream/alpakka/kinesis/KinesisWorkerSourceStage.scala
@@ -72,6 +72,7 @@ class KinesisWorkerSourceStage(
 
     override def postStop(): Unit = {
       hasBeenShutdown = true
+      buffer.clear()
       Future(worker.shutdown())
     }