我很高兴地宣布 Debezium 1.3.0.Alpha1 发布!
1.3 发布线中的这个初始版本提供了一些有用的新功能:
-
Azure Event Hubs 的新 Debezium Server sink 适配器
-
SQL Server 连接器的新快照模式
initial_only -
MongoDB 连接器的其他连接超时选项
总的来说,社区为这个版本修复了 不少于 31 个问题。让我们在本文的其余部分更详细地了解其中的一些。
Azure Event Hubs 接收适配器
MongoDB 连接选项增强
Debezium MongoDB 连接器传统上使用驱动程序的默认连接选项和超时。在某些用例中,需要自定义这些默认值以支持您的部署中的延迟或性能问题。
现在为 MongoDB 提供了额外的配置选项:
mongodb.connect.timeout.ms
驱动程序在放弃连接尝试之前等待新连接的毫秒数。
默认值为 10000。
mongodb.server.selection.timeout.ms
驱动程序选择服务器之前等待的毫秒数,超时后将抛出错误。
默认值为 30000。
mongodb.socket.timeout.ms
驱动程序在套接字发送/接收操作超时之前的等待毫秒数。
值为 0 则禁用此行为。默认值为 0。
其他功能
Bug 修复
此外,还修复了许多 Bug,例如:
-
忽略 Aurora 通过 SHOW TABLES 报告的非现有表(DBZ-1939)
-
Cassandra 连接器未获取事件(DBZ-2086)
-
PubSub Sink 发送空记录(DBZ-2277)
-
跳过 LSN 效率低下且不转发槽位位置(DBZ-2310)
-
包含可变位列的更改的消息大小至少大 68 倍(DBZ-2315)
-
连接器在处理具有 PK 更新的事务时重启,导致更改事件丢失(DBZ-2329)
-
处理与列表类型列相关的 commitLogs 时出错(DBZ-2345)
-
修复 Outbox Quarkus Extension 文档中的 dependency groupId(DBZ-2367)
-
无法检测 Azure SQL 版本(DBZ-2373)
-
ParallelSnapshotReader 有时会抛出 NPE(DBZ-2387)
请参阅 发行说明 以获取已解决问题的完整列表以及从早期 Debezium 版本升级的步骤。
非常感谢社区中所有为本次发布做出贡献的贡献者:Abhishek Gupta、Cory Harper、Arik Cohen、Moira Tagle、Victor Xiang、Grzegorz Kołakowski、Björn Häuser、Lukasz Korzeniowski 和 Jonas Lins!
关于 Debezium
Debezium 是一个开源的分布式平台,可以将现有数据库转变为事件流,使应用程序能够几乎即时地看到并响应数据库中已提交的每个行级更改。Debezium 构建在 Kafka 之上,并提供了 Kafka Connect 兼容的连接器,用于监控特定的数据库管理系统。Debezium 将数据更改的历史记录在 Kafka 日志中,这样您的应用程序可以随时停止和重新启动,并可以轻松地消费在未运行时错过的所有事件,确保所有事件都被正确且完整地处理。Debezium 在 Apache 许可证 2.0 下是 开源 的。