Hello, I have a flink job that reads from a source topic that currently has 4 partitions and I need to increase the partition count to 8.
Do you need to restart the job for that to take effect ? How does it work in case there is persistent state (like a window operator) involved ? Any design documents on how partition mapping works would be very helpful. Thanks Suraj
