Debezium日常分享系列之：Debezium 2.5.0.CR1发布

一、重大变化
- 1.Cloud Event 标头的架构名称
- 2.MySQL BIT 默认长度
二、新功能和改进
- 1.重新选择列
- 2.Debezium Server - 用于 Apache Kafka 接收器的 StreamNameMapper
- 3.增量快照水印的 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 的可能性。