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