我使用schema registry将avro消息写入kafka主题。然后根据主题创建流。使用当前架构创建的尖叫。然后将新字段添加到模式中。模式寄存器更新了,没关系,但流仍保留第一个结构。我可以用新的模式更新流吗?对我来说,删除并再次创建模式是有问题的,因为我有很多其他依赖它的流\表。ksql不允许删除具有依赖关系的流。
cbjzeqam1#
我认为最好的办法是停止溪流,让溪流流淌下来。https://docs.confluent.io/current/ksql/docs/developer-guide/create-a-stream.html#delete-a-ksql-流
1条答案
按热度按时间cbjzeqam1#
我认为最好的办法是停止溪流,让溪流流淌下来。
https://docs.confluent.io/current/ksql/docs/developer-guide/create-a-stream.html#delete-a-ksql-流