Join Slack
Powered by
Hii All I observed that Flink KafkaSource is not ...
# troubleshooting
r
Rashmin Patel
07/06/2023, 12:20 PM
Hii All I observed that Flink KafkaSource is not auto-detecting the increase in partitions of a source topic ? Is it expected behaviour ?
m
Martijn Visser
07/06/2023, 12:20 PM
Yes. You need to enable this yourself
r
Rashmin Patel
07/06/2023, 12:44 PM
Thanks Martin. Can you point me to the property to enable this ?
m
Martijn Visser
07/06/2023, 12:45 PM
Sure, that's
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#dynamic-partition-discovery
gratitude thank you
2
Open in Slack
Previous
Next