【发布时间】：2019-02-11 11:05:18
【问题描述】：
我使用模式注册表将 avro 消息写入 kafka 主题。 然后根据主题创建流。使用当前架构创建的尖叫声。
然后我将新字段添加到架构中。架构寄存器已更新，没关系，但流仍保留第一个结构。
我可以使用新架构更新流吗？
删除并再次创建架构对我来说是有问题的，因为我有很多其他依赖于它的流\表。 KSQL 不允许丢弃具有依赖关系的流。
【问题讨论】：
-
既然你已经有了新的模式，你可以创建一个新的流吗？一旦你有了新的流（基于新的模式），你就可以将你的应用程序指向这个新的流。
标签： apache-kafka confluent-platform ksqldb