如何基于 schema-registry 动态更新 KSQL 流定义

Question

我按照这个 创建了一个基于模式注册表的 KSQL 流。 Kafka JDBC 连接器更新架构注册表中的最新架构。新流是用最新的模式创建的，但现有流仍然在最旧的模式中。

我不知道数据源的架构何时更改。在这种情况下，我希望 KSQL 使用模式注册表中可用的最新模式动态刷新其定义。

有什么想法吗？如何实现？

Answer 1

目前您必须手动删除并重新创建一个流来获取新架构。

我已经记录了 #2215 如果你想 upvote/discuss 想要的行为在那里。