您正在查看 Debezium 未发布版本的文档。
如果您想查看此页面的最新稳定版本,请在此 查看。

后处理器

后置处理器会执行轻量级的、逐条消息的变异操作,类似于单消息转换(SMT)所执行的修改。然而,Debezium 在事件链中调用后置处理器的时机比转换要早,这使得后置处理器能够在消息被移交给消息运行时之前对其进行操作。由于后置处理器可以在 Debezium 上下文内部对消息进行操作,因此它们在修改事件负载方面比转换更有效。

为了修改消息,转换器必须重新创建消息的不可变 ConnectRecord,或者更确切地说,是它的 SourceRecord。相比之下,由于后置处理器在 Debezium 的作用域内运行,它可以操作消息事件负载中的可变 Struct 类型,在构建 SourceRecord 之前修改负载。与 Debezium 的紧密集成使后置处理器能够访问 Debezium 的内部信息,例如关于数据库连接、关系模式模型等的 Debezium 元数据。反过来,这种访问可以提高执行依赖于此类内部信息的任务的效率。

Debezium 提供了以下后置处理器实现:

后置处理器 描述

重新选择可能未由更改事件提供的特定列,例如 TOASTed 列或 Oracle LOB 列,这些列未被当前事件的更改所修改。

后置处理器旨在仅修改由 Debezium 源连接器发出的更改事件记录。
您不能将 Debezium JDBC sink 连接器配置为使用后置处理器。