Hi, Cranmer. I'm Roland Wang. I've read the FLIP you wrote, and agree with your design. Recently, I'm working on this feature too, and have made some progress:
1. I add two methods: getOrRegisterConsumer & subscribeToShard on KinesisProxyInterface. 2. I re-implement the KinesisProxy using AWS SDK V2.x. 3. I use the new KinesisProxy to implement ShardConsumer. Though my design is not fully considered, I hope we can discuss a little bit about this feature. I wish to make some contribution to the community. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
