ConstantRecordCountMemoryBuffer is an implementation of the IBuffer interface. It ensures that records are periodically flushed with the same record count.
Flushing a constant number of records is essential to the proper handling of duplicates on the consumer end as documented here:
ConstantRecordCountMemoryBuffer is an implementation of the IBuffer interface. It ensures that records are periodically flushed with the same record count.
Flushing a constant number of records is essential to the proper handling of duplicates on the consumer end as documented here:
http://docs.aws.amazon.com/streams/latest/dev/kinesis-record-processor-duplicates.html