ReactoKinesix


0.5.0 - July 31, 2015

  • re-aqcuire shard iterator in the event that the current iterator has expired
  • record time behind tip of stream & timestamp of checkpoint in state table

0.4.0 - May 8, 2015

  • for background/scheduled tasks start them on the current thread over always queue it up to threadpool
  • only fetch after successful processing
  • allow consumer to configure max batch size

0.3.0 - Oct 7, 2014

  • shard ID is passed to the shard processor

0.2.1 - Oct 3, 2014

Bug fix: - fixed 'The input sequence was empty.' exception when attempting to share load

0.2.0 - Sep 30, 2014

Breaking changes: - record processor processes batch at a time - record processor needs to respond with status and whether or not to place checkpoint after each batch - kinesis app takes in a processor factory instead of processor instance

Bug fixes: - fixed bug with wrong type of exception being checked in DynamoDBUtils.createTable - fixed bug where ShardId attribute is assumed to be always present even when there's no data in the table - handle exceptions other than ResourceNotFound during init state table phase

Minor: - added stubs for dynamodb and kinesis - added unit tests - updated log4net and AWSSDK dependencies to latest

0.2.0-beta - Mar 10, 2014

Breaking changes: - record processor processes batch at a time - record processor needs to respond with status and whether or not to place checkpoint after each batch - kinesis app takes in a processor factory instead of processor instance

Bug fixes: - fixed bug with wrong type of exception being checked in DynamoDBUtils.createTable - fixed bug where ShardId attribute is assumed to be always present even when there's no data in the table - handle exceptions other than ResourceNotFound during init state table phase

Minor: - added stubs for dynamodb and kinesis - added unit tests

0.1.0 - Jan 01, 2014

  • Initial release
Fork me on GitHub