您正在查看过时的Debezium版本的文档。开云体育官方注册网址
如果您想查看本页最新的稳定版本,请前往在这里

发送信号到Debezium连接器开云体育官方注册网址

该功能目前处于孵化状态,即准确的语义,配置选项等可能会根据我们收到的反馈在未来的版本中改变。请让我们知道,如果你遇到任何问题,而使用这个扩展。

概述

有时用户有必要修改连接器行为或触发一次性操作(例如单个表的快照)。为了满足这样的需求,Debezium提供了一开云体育官方注册网址种机制,如何向Debezium连接器发送信号以触发操作。由于可能需要将这样的操作与数据流同步,因此信号被实现为对数据集合的写入。

缺省情况下,信令是禁用的。信令数据收集的名称必须通过连接器配置参数设置以启用该功能。信令数据采集必须是外显在捕获的数据集合中添加。

表1。连接器配置
参数 描述

signal.data.collection

数据收集的完全限定名称。
名称格式是特定于连接器的,例如。"some_schema.开云体育官方注册网址debezium_signals"用于Debezium Postgres连接器。

数据采集结构

信令数据收集必须符合要求的格式:它必须包含三个字段;字段的命名是任意的,只有字段的顺序是重要的。建议但不是强制使用下表中定义的字段名:

表2。信令数据采集结构
类型 描述

id

字符串

此信号实例的唯一标识符。
它可以用于日志记录、调试或重复数据删除。通常是UUID字符串。

类型

字符串

要发送的信号类型。
有对所有连接器都通用的信号,也有特定于连接器子集的信号。

数据

字符串

传递给信号操作的JSON格式参数。
每个信号都有自己的预期数据集。

表3。一个信号记录的例子
价值

id

924 e3ff8 - 2245 - 43 - ca - ba77 af9af02fa07——2

类型

日志

数据

{"message": "偏移量{}处的信号消息"}

信号行为

这些信号对所有连接器都是通用的

日志记录

日志操作的类型为日志.它会将提供的消息打印到日志中,可选地包括流位置。

表4。操作参数
的名字 描述

消息

打印到日志中的字符串。
如果占位符{}添加到消息中,该消息将被流坐标替换。

表5所示。日志记录的示例
价值

id

924 e3ff8 - 2245 - 43 - ca - ba77 af9af02fa07——2

类型

日志

数据

{"message": "偏移量{}处的信号消息"}