如何基于schema注册表动态更新ksql流定义

q43xntqr  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(282)

我根据本文创建了一个基于schema registry的ksql流。kafka jdbc连接器更新schema registry中的最新模式。新的流是用最新的模式创建的,而现有的流是用最旧的模式创建的。
我不知道数据源的模式什么时候会改变。在本例中,我希望ksql使用schema registry中可用的最新模式动态刷新其定义。
你知道吗?如何做到这一点?

brqmpdu1

brqmpdu11#

此时,您必须手动删除并重新创建一个流来获取新的模式。
如果你想在那里投票/讨论你想要的行为,我已经记录了2215条。

相关问题