Skip to content

Commit

Permalink
Fixes Kinesis Internal Telem. on Batch Success (#404)
Browse files Browse the repository at this point in the history
Kinesis sink now properly increments SUCCESS_SUM when the entire batch
succeeds.
  • Loading branch information
pulltab authored Jan 25, 2018
1 parent c6abe6b commit f50a892
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/sink/kinesis.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down

0 comments on commit f50a892

Please sign in to comment.