4

我使用模式注册表将 avro 消息写入 kafka 主题。然后根据主题创建流。使用当前模式创建的尖叫声。

然后我将新字段添加到架构中。模式寄存器已更新，没关系，但流仍保留第一个结构。

我可以使用新架构更新流吗？

再次删除和创建模式对我来说是有问题的，因为我有很多其他依赖于它的流\表。KSQL 不允许丢弃具有依赖关系的流。

4

1 回答 1

0

我认为最好的方法是停止流和 DROP STREAM MYSTREAM。

https://docs.confluent.io/current/ksql/docs/developer-guide/create-a-stream.html#delete-a-ksql-stream

于 2019-03-12T11:27:24.657 回答