Hi,

I'm wondering if anyone has changed the number of partitions of a source
Kafka topic.

Let's say I have a Flink job read from a Kafka topic which used to have 32
partitions. If I change the number of partitions of that topic to 64, can
the Flink job still guarantee the exactly-once semantics?

Thanks.

Thomas

Reply via email to