daangn / kinesumer

A Go client implementing a client-side distributed consumer group client for Amazon Kinesis
Apache License 2.0
76 stars 6 forks source link

Ability to choose where to start in the stream(s) #22

Open jfalkenstein opened 1 year ago

jfalkenstein commented 1 year ago

I realized today that when the Shard Iterators are obtained for the first time, they have the "latest" position hard-coded. I'd really like to see this be something configurable so that we could use TRIM_HORIZON or any of the other possible values. Defaulting to Latest is rather inconvenient if you need to catch up on missed records already in the stream.