Kinesis Consumer Versions Save

Golang library for consuming Kinesis stream data

v0.3.5

2 years ago

Final cut before moving to AWS SDK v2

v0.3.4

3 years ago

Haven't cut a release in a LONG time and there are several features (such as ScanInterval) and bugs fixed since v0.3.3

v0.3.2

4 years ago

This will be the last Tagged release before adding consumer groups: https://github.com/harlow/kinesis-consumer/issues/42

While the intention will be to keep master stable at all times, there are going to be some breaking changes around naming Checkpoint -> Storage and new Group interface.

v0.3.1

5 years ago

Going forward the concept of ScanStatus will be removed from the codebase. This will act as the final release before the breaking change is introduced into main branch.

There are a few bug fixes in this release too:

  • Moving cancellation of consumers into the error block (previously if a shard was closed all consumers would be signaled to shutdown)

v0.3.0

5 years ago

Having an additional Client has added some confusion (#45) on how to provide a custom kinesis client. Allowing WithClient to accept a Kinesis client it cleans up the interface.

Major changes:

  • Remove the Client wrapper; prefer using kinesis client directly
  • Change ScanError to ScanStatus as the return value isn't necessarily an error

Minor changes:

  • Additional test coverage

v0.2.0

5 years ago