信息过滤

出于安全原因，筛选器SMT没有包含在Debezium连接器存档中。开云体育官方注册网址相反，它是在一个单独的工件中提供的，开云体育官方注册网址debezium-scripting-2.1.2.Final.tar.gz．

要使用基于内容的路由SMT和Debezium连接器插件，必须显式地将SMT工件添加到Ka开云体育官方注册网址fka Connect环境中。重要提示:在Kafka Connect实例中出现筛选器SMT之后，任何被允许向实例添加连接器的用户都可以运行脚本表达式。为了确保脚本表达式只能由授权用户运行，在添加筛选器SMT之前，请确保Kafka Connect实例及其配置接口的安全。

与动物园管理员，卡夫卡，卡夫卡连接，并且安装了一个或多个Debeziu开云体育官方注册网址m连接器，安装过滤器SMT的剩余任务是:

Groovy语言在类路径上需要以下库:

JavaScript语言在类路径上需要以下库:

在Debezium连接器的Kafka Connect配置中配置过滤器转换。开云体育官方注册网址在配置中，您可以通过定义基于业务规则的筛选条件来指定感兴趣的事件。当筛选器SMT处理事件流时，它根据配置的筛选条件评估每个事件。只有满足筛选条件条件的事件才被传递给代理。

要配置Debezium连接器以开云体育官方注册网址过滤更改事件记录，请配置过滤器SMT在Kafka Connect配置的Debezium连接器。开云体育官方注册网址筛选器SMT的配置要求您指定一个定义筛选条件的正则表达式。

例如，您可以在连接器配置中添加以下配置。

属性的使用Groovy表达式语言。正则表达式价值。人事处== 'u' && value.before.id == 2删除所有消息，除了表示更新(u)记录与id等于的值2．

前面的示例显示了一个简单的SMT配置，该配置被设计为仅处理DML事件，其中包含人事处字段。连接器可能发出的其他类型的消息(心跳消息、墓碑消息或关于模式更改和事务的元数据消息)不包含此字段。为了避免处理失败，您可以定义选择性地应用转换的SMT谓词语句仅用于特定事件。

开云体育官方注册网址Debezium将某些变量绑定到过滤器SMT的计算上下文中。当您创建表达式来指定筛选条件时，您可以使用Debezium绑定到计算上下文中的变量。开云体育官方注册网址通过绑定变量，Debezium使SMT能够在开云体育官方注册网址计算表达式中的条件时查找和解释变量的值。

下表列出了Debezium绑定到过滤器SMT的计算上下文中的变量:开云体育官方注册网址

表达式可以对其变量调用任意方法。表达式应该解析为一个布尔值，该值决定SMT如何处理消息。当表达式中的筛选条件计算为时真正的，该消息将被保留。当筛选条件计算为时假，消息被删除。

表达式不应该导致任何副作用。也就是说，它们不应该修改传递的任何变量。

除了发生数据库更改时Debezium连接器发出的更改事件消息外，连接器还发出其他类型的消息，包括开云体育官方注册网址心跳消息和关于模式更改和事务的元数据消息。开云体育电动老虎机因为这些其他消息的结构与SMT设计用来处理的更改事件消息的结构不同，所以最好将连接器配置为选择性地应用SMT，以便它只处理预期的数据更改消息。您可以使用以下方法之一来配置连接器以选择性地应用SMT:

表达过滤条件的方式取决于所使用的脚本语言。

例如，如基本配置示例，当你使用Groovy作为表达式语言，下面的表达式删除所有消息，除了已删除的更新记录id设置为2：

其他语言用不同的方法来表达相同的条件。

如果使用JavaScript作为表达式语言，则可以调用结构体# get ()方法指定过滤条件，示例如下:

如果您使用JavaScript和Graal.js来定义过滤条件，那么您使用的方法与Groovy使用的方法类似。例如:

下表列出了可以与筛选器SMT一起使用的配置选项。