Hello
To learn Flink I'm trying to build a simple application where I want to save events coming from Kinesis to S3. I want to subscribe to each shard, and within each shard I want to batch for 30 seconds, or until 1000 events are observed. These batches should then be uploaded to S3. What I don't understand is how to key my source on shard id, and do it in a way that doesn't induce unnecessary shuffling. Is this possible with Flink?
