2.1.0

Added

• Use Meta Auth if secretKey or authKey is empty string

2.0.7

Fixed

• Will retry sending records to firehose if the response is nil due to unexpected connection error or termination

2.0.6

Fixed

• Retry posting potentially lost records in edge case of connection termination or other unexpected error

2.0.5

Fixed

• Fixes for expired shard iterator and kinesis client connection termination.

2.0.4

Fixed

• Stack overflow in addMessage that would occur when processing a large number of initial records from the stream

Fixed Deadlocks; Setting Sequence Number

Fixed

• Deadlock when msgBuffer was incorrectly decremented when there were no messages on the channel
• Sequence number never being set when attempting to refresh the shard iterator in the event of an error

Added concurrency settings; Decreased pause time

Added

• Ability to specify concurrency for Listeners and Producers in constructor

Modified

• Pause time for reads to occur between writes

Added concurrency settings; Decreased pause time

Added

• Ability to specify concurrency for Listeners and Producers in constructor

Modified

• Pause time for reads to occur between writes

Updated API and Firehose Integration

Updated API and Firehose Integration

Changed

• InitWithConf changed to InitC
• FirehoseWithConf changed to FirehoseC

Added

• Firehose integration

Custom constructor with configuration override

Added

• custom constructor with configuration override