В последнее время мы выполняем потоковую работу с Apache Flink.Существует несколько тем KAFKA в формате xxxxxx_yy-mm-dd.Мы использовали шаблон регулярных выражений, чтобы позволить потребителю использовать эти темы.Однако, если мы удаляем некоторые старые темы, кажется, что метаданные в потребителе не обновляются должным образом.Это все еще помнит те устаревшие темы в своем списке тем?поэтому UNKNOWN_TOPIC_EXCEPTIOIN .Мы должны перезапустить работу потребителя для восстановления.Похоже, это происходит и у продюсера.Есть идеи, чтобы решить эту проблему?Большое спасибо!