最近我们正在用apache flink做一些流媒体工作。有多个kafka主题，格式为\u yy-mm-dd。我们使用主题regex模式让消费者使用这些主题。但是，如果我们删除一些旧的主题，那么消费者中的元数据似乎没有正确更新。它还记得主题列表中那些过时的主题吗？所以未知的主题例外。我们必须重新启动使用者作业才能恢复。它似乎也发生在生产者。有什么办法解决这个问题吗？非常感谢你！