广州网站设计培训,小程序链接生成二维码,wordpress的页面的,双通网络网站建设Debezium日常分享系列之#xff1a;Debezium 2.5.0.CR1发布 一、重大变化1.Cloud Event 标头的架构名称2.MySQL BIT 默认长度 二、新功能和改进1.重新选择列2.Debezium Server - 用于 Apache Kafka 接收器的 StreamNameMapper3.增量快照水印的 INSERT/DELETE 语义4.Debezium 服… Debezium日常分享系列之Debezium 2.5.0.CR1发布 一、重大变化1.Cloud Event 标头的架构名称2.MySQL BIT 默认长度 二、新功能和改进1.重新选择列2.Debezium Server - 用于 Apache Kafka 接收器的 StreamNameMapper3.增量快照水印的 INSERT/DELETE 语义4.Debezium 服务器 - AWS SQS 接收器5.Oracle LOB 行为 Debezium 2.5.0.CR1 现已推出。此版本包括许多改进例如 Debezium Server 的 AWS SQS 接收器、增量快照水印的 INSERT/DELETE 语义、ReselectColumnsPostProcessor、统一的 Oracle LOB 行为。
一、重大变化
此版本包含多项重大更改。
1.Cloud Event 标头的架构名称
Cloud Event 标头的架构名称前缀和字母大小写与负载名称不一致。架构名称已对齐因此标头和有效负载共享相同的命名空间并遵循相同的字母大小写规则 。
2.MySQL BIT 默认长度
如果没有设置的话MySQL BIT 数据类型没有隐式长度。这是不正确的因为如果未提供则默认长度为 1。
二、新功能和改进
Debezium 2.5 还引入了更多改进和功能让我们分别看一下。
1.重新选择列
在某些情况下由于某些源数据库的工作方式当 Debezium 连接器发出更改事件时该事件可能会排除特定列类型的值。例如PostgreSQL 中的 TOAST 列、Oracle 中的 LOB 列或 Oracle Exadata 中的扩展字符串列的值可能全部被排除。
Debezium 2.5 引入了 ReselectColumnsPostProcessor提供了一种从数据库表中重新选择一个或多个列并获取当前状态的方法。可以配置后处理器以重新选择以下列类型
空列。包含 unavailable.value.placeholder 标记值的列。
配置 PostProcessor 与配置 CustomConverter 或 Transformation 类似不同之处在于它适用于可变负载的 Struct 而不是 SourceRecord。
2.Debezium Server - 用于 Apache Kafka 接收器的 StreamNameMapper
现在可以通过自定义逻辑修改 Kafka 接收器行为为特定功能提供替代实现。当替代实现不可用时则使用默认实现。
3.增量快照水印的 INSERT/DELETE 语义
引入了属性incremental.snapshot.watermarking.strategy让用户可以选择在增量快照期间使用的水印策略。
insert_insert旧行为方法让 Debezium 在快照期间为每个块在信令数据集合中创建两个条目以发出快照窗口打开的信号并使用另一个条目来标记其关闭。
另一方面使用 insert_delete 选项在窗口开头的每个块的信令数据集合中写入单个条目。完成后该条目被删除并且不再添加相应的条目以表示快照窗口的关闭。该方法有助于更有效地管理信令数据收集。
4.Debezium 服务器 - AWS SQS 接收器
Amazon Simple Queue Service (Amazon SQS) 是一种分布式消息队列服务。它支持通过 Web 服务应用程序以编程方式发送消息作为通过 Internet 进行通信的一种方式。 SQS 旨在提供高度可扩展的托管消息队列解决常见的生产者-消费者问题或生产者与消费者之间的连接问题。
Debezium 2.5 提供了将事件发送到 Amazon SQS 的可能性。
5.Oracle LOB 行为
Debezium 2.5 调整了快照和流中的 LOB 行为。当 lob.enabled 设置为 false 时将在快照期间显式包含不可用值占位符以匹配流的行为。
