From f50a892e3b0ef82edf71a636be29d3b742e4c550 Mon Sep 17 00:00:00 2001
From: John Koenig <john@calledshot.org>
Date: Thu, 25 Jan 2018 11:17:25 -0600
Subject: [PATCH] Fixes Kinesis Internal Telem. on Batch Success (#404)

Kinesis sink now properly increments SUCCESS_SUM when the entire batch
succeeds.
---
 src/sink/kinesis.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/sink/kinesis.rs b/src/sink/kinesis.rs
index 871e1d64..4065b116 100644
--- a/src/sink/kinesis.rs
+++ b/src/sink/kinesis.rs
@@ -200,6 +200,7 @@ impl Kinesis {
         if put_records_output.failed_record_count.is_none()
             || put_records_output.failed_record_count == Some(0)
         {
+            KINESIS_PUBLISH_SUCCESS_SUM.fetch_add(self.put_records_input.records.len(), Ordering::Relaxed);
             self.put_records_input.records.clear();
             return;
         }