我根据本文创建了一个基于schema registry的ksql流。kafka jdbc连接器更新schema registry中的最新模式。新的流是用最新的模式创建的,而现有的流是用最旧的模式创建的。我不知道数据源的模式什么时候会改变。在本例中,我希望ksql使用schema registry中可用的最新模式动态刷新其定义。你知道吗?如何做到这一点?
brqmpdu11#
此时,您必须手动删除并重新创建一个流来获取新的模式。如果你想在那里投票/讨论你想要的行为,我已经记录了2215条。
1条答案
按热度按时间brqmpdu11#
此时,您必须手动删除并重新创建一个流来获取新的模式。
如果你想在那里投票/讨论你想要的行为,我已经记录了2215条。