Thanks, I'll check it out.
On Mon, Apr 20, 2020 at 6:23 PM Benchao Li wrote:
> Hi Suraj,
>
> There is a config option[1] to enable partition discovery, which is
> disabled by default.
> The community discussed to enable it by default[2], but only aims to the
> new Source API.
>
> [1]
> https://c
Hi Suraj,
There is a config option[1] to enable partition discovery, which is
disabled by default.
The community discussed to enable it by default[2], but only aims to the
new Source API.
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#partition-discovery
[2]
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 doc
