我们很高兴地宣布,**Debezium 0.3.5** 现在可以与 Kafka Connect 0.10.0.1 一起使用。此版本包含对 MySQL 连接器的几项修复,并增加了与 多主 MySQL 服务器 作为源一起使用的能力。有关这些更改的详细信息,请参阅 发行说明。我们还更新了标记为 0.3 和 latest 的 Debezium Docker 镜像,我们在 教程 中使用了这些镜像。
其中一项修复非常重要,因此**我们强烈建议所有用户从所有早期版本升级到此版本。**在以前的版本中,MySQL 连接器可能会在未完成事务中的所有更新的情况下停止,并且当连接器重新启动时,它会从下一个事务开始,因此可能无法捕获前一个事务中的某些更改事件。此版本修复了此问题,因此在重新启动时,即使在事务中间,它也将始终从中断的地方继续。请注意,此修复仅在连接器升级并重新启动后才生效。有关更多详细信息,请参阅 此问题。
感谢 Akshath、Anton、Chris 以及其他人在此次发布、问题、讨论、贡献和提问方面的帮助!
关于 Debezium
Debezium 是一个开源的分布式平台,可以将现有数据库转变为事件流,使应用程序能够几乎即时地看到并响应数据库中已提交的每个行级更改。Debezium 构建在 Kafka 之上,并提供了 Kafka Connect 兼容的连接器,用于监控特定的数据库管理系统。Debezium 将数据更改的历史记录在 Kafka 日志中,这样您的应用程序可以随时停止和重新启动,并可以轻松地消费在未运行时错过的所有事件,确保所有事件都被正确且完整地处理。Debezium 在 Apache 许可证 2.0 下是 开源 的。