harlow
harlow
@anton-pfc sorry if there is confusion here; there isn't a way to run 10 consumer apps all with `Scan` func and not have them all consume the same records. If...
hi @bryanpaluch there is the option to use `ScanShard` to scan a single shard. https://github.com/harlow/kinesis-consumer/blob/master/consumer.go#L156-L159 In this case each process would need specify the shardID before kicking off the scan:...
> I believe the checkpoint package would need an interface for locking access to a shard. Trying to unravel the desired functionality here a little... Seems like there are two...
Hi @yeoji I'm afraid we lost traction on it. I'll remove that notice from the README for the time being
Hi thanks for submitting the PR; I'm struggling a little with the amt of duplication between the two function; my fear is "drift" between the two makes this code path...
thanks for the note, I'll take a look at this over the weekend 👍
nice catch. the `main` branch now uses AWS SDK V2, and this will now use the upstream aggregation library
hi @etsangsplk can you give a code example of where you'd like to pass the context? i'm fine w/ a breaking change if it makes the library easier to work...
Hi @etsangsplk while overall I think https://github.com/harlow/kinesis-consumer/pull/72 looks good. I've been trying to get my head around if we need all the open-tracing code scattered around the repo. Or if...
Hi thanks for the note. Agree that could be a nice interface. I've just used a channel in the callback func in the past, but agree this would be a...