物化视图应该如何迁移当存储的对象字段被改变(类型,字段数等)?你能告诉我需要的步骤或给我一份文件吗?有好的实践吗?如果AVRO
模式求值?向前/向后兼容性重要吗?Kafka Streams API中有状态流(KTable
)是如何处理的?有关于这个话题的文章吗?
格式/兼容性并不完全重要,除非您需要确保新模式可以反序列化旧数据,即"向后兼容"。但如果不可能的话,你也可以在新数据的开始处寻找任何消费者…
您需要重置应用程序,然后基于新模式重建所有输出流和表。