Resharding Kinesis and the Enricher


#1

Hello,

We’re looking to optimize our costs and to re-shard the data-sink Kinesis queue (post-enricher) based on the realtime load. I know the enricher stores high-watermarks in DynamoDB - which is a complication for zero-downtime (or short downtime) resharding. Is this even possible?

We’re thinking of doing a variant of green/blue deploys whereby we’ll spin up a parallel enricher + kinesis queue + consumer lambda with the revised amount of shards, do a switch either in Elastic IP or ELB, let the old one drain out and take it out of commission. I was just wondering whether there’s a less heavy-handed approach. Let’s investigate this together!

Victor


#2

Hi @vivricanopy - it’s totally possible to do dynamic re-sharding (splits and merges) of each stream in situ.

There’s no need to spin up a parallel pipeline unless you need to do a breaking change of the actual contents of a stream.

I presented on the autoscaling/monitoring tech, called Tupilak, which we use to achieve this for our Managed Service Real-Time customers at Snowplow London Meetup #3 last night, here are the slides, I hope they’re helpful:

Introducing Tupilak, Snowplow's unified log fabric from Alexander Dean

#3

Hi @vivricanopy,

I have been playing for a while with both, Amazon KCL library (the library reals tack is based) and Snowplow kinesis stack and Kinesis stream resharding. I have not seen any issues. The library workers were able to pick up new streams, eat form old with data and so on. Everything works automagically. No need to do anything:-)

Hint: in dynamo you may find shard iterator and shard id so workers pick up what is available.


#4

Thanks @alex and @grzegorzewald!