kafka producer 可以动态更新到新扩容的分区吗?

[ぐ绿み翼う]

kafka source 可以通过flink.partition-discovery.interval-millis 参数来实现动态发现新扩容到分区但是kafka sink没有找到类似的选项，查看源码发现 partition的获取会被缓存在一个map中，并且一次获取后不会再更新


int[] partitions = (int[])this.topicPartitionsMap.get(targetTopic);
if (null == partitions) {
    partitions = getPartitionsByTopic(targetTopic, transaction.producer);
    this.topicPartitionsMap.put(targetTopic, partitions);
}求教下社区目前有没有方式可以实现这个功能，或者有没计划实现这个功能？