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

Question

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

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

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

Answer 1

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

我已经登录 #2215如果您想在那里投票/讨论所需的行为。