Hi Team, I am running flink 1.11 kinesis consumer with say N kinesis shards, but i want to increase/decrease shards to N+M or N-M. Once i do that my flink consumer need to be restarted with changed parallelism. But i am unable to restart from existing checkpoint because of change in number of shards.
How do i solve this problem of restarting from existing checkpoint which was created with respect to N shards but now while restating we have more or less shards? Thanks, Vijay
