У меня есть FlinkKafkaConsumer11 с регулярным выражением.Он слушает существующие темы, удовлетворяющие Regex, но вновь созданные темы не обнаруживаются.После перезапуска задания он начинает обнаруживать и эти темы.Я хочу, чтобы он обнаруживал все темы, удовлетворяющие регулярному выражению, без перезапуска.
Как предлагается в документации, я добавил ниже в свойствах:
props.put("metadata.max.age.ms", 5000);
props.put(FlinkKafkaConsumer011.KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS, 5000);
, но он все еще не работает.