Thanks Danny, Let me comeback with results.
>
> On Feb 23, 2022, at 3:41 AM, Danny Cranmer wrote:
>
>
> Hello Vijay,
>
> > Once i do that my flink consumer need to be restarted with changed
> > parallelism.
> Why is this? The Flink consumer continuously scans for new shards, and will
> aut
Hello Vijay,
> Once i do that my flink consumer need to be restarted with changed
parallelism.
Why is this? The Flink consumer continuously scans for new shards, and will
auto scale up/down the number of shard consumer threads to
accommodate Kinesis resharding. Flink job/operator parallelism does
