It will just work as long as you enable partition discovery. https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#partition-discovery
On Tue, Jun 22, 2021 at 1:32 PM Thomas Wang <w...@datability.io> wrote: > 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 >
