我想知道是否有一个文档化的过程来处理数据库模式的更改。我正在使用Debezium source connector for postgres和confluent JDBC Sink connector来复制数据库更改。我需要在数据库中做一些更改，如下所示
1.将新列添加到现有表
1.修改数据库列类型并更新名称。
我不知道什么是最好的方法来做到这一点。解决方案，我可以认为，如果是
1.停止源连接器
1.等待接收器使用所有消息
1.升级数据库
1.启动源和接收器连接器
我想知道是否有一个文档化的过程来处理数据库模式的更改。我正在使用Debezium source connector for postgres和confluent JDBC Sink connector来复制数据库更改。我需要在数据库中做一些更改，如下所示
1.将新列添加到现有表
1.修改数据库列类型并更新名称。
我不知道什么是最好的方法来做到这一点。解决方案，我可以认为，如果是
1.停止源连接器
1.等待接收器使用所有消息
1.升级数据库
1.启动源和接收器连接器
1条答案
按热度按时间lvjbypge1#
Debezium会自动在记录模式中为新列添加新字段。因此，您需要首先更新您的消费者和下游系统，以便为这些事件做好准备。无需停止源...
在更改类型和名称时，可能会遇到向后不兼容的方案更改，通常不建议执行这些操作。请始终添加新列，但“弃用”并且不要使用旧列。在所有其他系统中阅读完这些旧列的事件后，请删除这些列。