用新的主题模式更新ksql流

6za6bjd0  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(328)

我使用schema registry将avro消息写入kafka主题。然后根据主题创建流。使用当前架构创建的尖叫。
然后将新字段添加到模式中。模式寄存器更新了,没关系,但流仍保留第一个结构。
我可以用新的模式更新流吗?
对我来说,删除并再次创建模式是有问题的,因为我有很多其他依赖它的流\表。ksql不允许删除具有依赖关系的流。

cbjzeqam

cbjzeqam1#

我认为最好的办法是停止溪流,让溪流流淌下来。
https://docs.confluent.io/current/ksql/docs/developer-guide/create-a-stream.html#delete-a-ksql-流

相关问题