Jump To Close Expand all Collapse all Table of contents Debezium 用户指南 前言 1. Debezium 的高级别概述 Expand section "1. Debezium 的高级别概述" Collapse section "1. Debezium 的高级别概述" 1.1. Debezium 功能 1.2. Debezium 架构描述 2. 所需的自定义资源升级 3. Db2 的 Debezium 连接器 Expand section "3. Db2 的 Debezium 连接器" Collapse section "3. Db2 的 Debezium 连接器" 3.1. Debezium Db2 连接器概述 3.2. Debezium Db2 连接器如何工作 Expand section "3.2. Debezium Db2 连接器如何工作" Collapse section "3.2. Debezium Db2 连接器如何工作" 3.2.1. Debezium Db2 连接器如何执行数据库快照 Expand section "3.2.1. Debezium Db2 连接器如何执行数据库快照" Collapse section "3.2.1. Debezium Db2 连接器如何执行数据库快照" 3.2.1.1. 临时快照 3.2.1.2. 增量快照 3.2.1.3. 触发增量快照 3.2.1.4. 停止增量快照 3.2.2. Debezium Db2 连接器如何读取更改数据表 3.2.3. 接收 Debezium Db2 更改事件记录的 Kafka 主题默认名称 3.2.4. 关于 Debezium Db2 连接器模式更改主题 3.2.5. Debezium Db2 连接器生成的事件代表事务边界 3.3. Debezium Db2 连接器数据更改事件的描述 Expand section "3.3. Debezium Db2 连接器数据更改事件的描述" Collapse section "3.3. Debezium Db2 连接器数据更改事件的描述" 3.3.1. 关于 Debezium db2 中的键更改事件 3.3.2. 关于 Debezium Db2 更改事件中的值 3.4. Debezium Db2 连接器如何映射数据类型 3.5. 设置 Db2 以运行 Debezium 连接器 Expand section "3.5. 设置 Db2 以运行 Debezium 连接器" Collapse section "3.5. 设置 Db2 以运行 Debezium 连接器" 3.5.1. 配置 Db2 表以更改数据捕获 3.5.2. Db2 捕获代理配置对服务器负载和延迟的影响 3.5.3. Db2 捕获代理配置参数 3.6. 部署 Debezium Db2 连接器 Expand section "3.6. 部署 Debezium Db2 连接器" Collapse section "3.6. 部署 Debezium Db2 连接器" 3.6.1. 获取 Db2 JDBC 驱动程序 3.6.2. 使用 AMQ Streams 部署 Db2 连接器 3.6.3. 使用 AMQ Streams 部署 Debezium Db2 连接器 3.6.4. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium Db2 连接器 3.6.5. 验证 Debezium Db2 连接器正在运行 3.6.6. Debezium Db2 连接器配置属性的描述 3.7. 监控 Debezium Db2 连接器性能 Expand section "3.7. 监控 Debezium Db2 连接器性能" Collapse section "3.7. 监控 Debezium Db2 连接器性能" 3.7.1. 在 Db2 数据库的快照期间监控 Debezium 3.7.2. 监控 Debezium Db2 连接器记录流 3.7.3. 监控 Debezium Db2 连接器模式历史记录 3.8. 管理 Debezium Db2 连接器 3.9. 更新 Debezium 连接器捕获模式的 Db2 表的模式 Expand section "3.9. 更新 Debezium 连接器捕获模式的 Db2 表的模式" Collapse section "3.9. 更新 Debezium 连接器捕获模式的 Db2 表的模式" 3.9.1. 为 Debezium Db2 连接器执行离线 schema 更新 3.9.2. 为 Debezium Db2 连接器执行在线 schema 更新 4. MongoDB 的 Debezium 连接器 Expand section "4. MongoDB 的 Debezium 连接器" Collapse section "4. MongoDB 的 Debezium 连接器" 4.1. Debezium MongoDB 连接器概述 Expand section "4.1. Debezium MongoDB 连接器概述" Collapse section "4.1. Debezium MongoDB 连接器概述" 4.1.1. MongoDB 连接器如何使用更改流捕获事件记录的描述 4.2. Debezium MongoDB 连接器的工作方式 Expand section "4.2. Debezium MongoDB 连接器的工作方式" Collapse section "4.2. Debezium MongoDB 连接器的工作方式" 4.2.1. Debezium 连接器支持的 MongoDB 拓扑 4.2.2. Debezium MongoDB 连接器如何为副本集和分片集群使用逻辑名称 4.2.3. Debezium MongoDB 连接器如何执行快照 Expand section "4.2.3. Debezium MongoDB 连接器如何执行快照" Collapse section "4.2.3. Debezium MongoDB 连接器如何执行快照" 4.2.3.1. 临时快照 4.2.3.2. 增量快照 4.2.3.3. 触发增量快照 4.2.3.4. 停止增量快照 4.2.4. Debezium MongoDB 连接器流更改事件记录 4.2.5. MongoDB 支持在 Debezium 更改事件中填充 before 字段 4.2.6. 接收 Debezium MongoDB 更改事件记录的 Kafka 主题默认名称 4.2.7. Debezium MongoDB 连接器的事件键控制主题分区的方式 4.2.8. Debezium MongoDB 连接器生成的事件代表事务边界 4.3. Debezium MongoDB 连接器数据更改事件的描述 Expand section "4.3. Debezium MongoDB 连接器数据更改事件的描述" Collapse section "4.3. Debezium MongoDB 连接器数据更改事件的描述" 4.3.1. 关于 Debezium MongoDB 更改事件中的键 4.3.2. 关于 Debezium MongoDB 更改事件中的值 4.4. 设置 MongoDB 以使用 Debezium 连接器 4.5. 部署 Debezium MongoDB 连接器 Expand section "4.5. 部署 Debezium MongoDB 连接器" Collapse section "4.5. 部署 Debezium MongoDB 连接器" 4.5.1. 使用 AMQ Streams 部署 MongoDB 连接器 4.5.2. 使用 AMQ Streams 部署 Debezium MongoDB 连接器 4.5.3. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium MongoDB 连接器 4.5.4. 验证 Debezium MongoDB 连接器是否正在运行 4.5.5. Debezium MongoDB 连接器配置属性的描述 4.6. 监控 Debezium MongoDB 连接器性能 Expand section "4.6. 监控 Debezium MongoDB 连接器性能" Collapse section "4.6. 监控 Debezium MongoDB 连接器性能" 4.6.1. 在 MongoDB 快照过程中监控 Debezium 4.6.2. 监控 Debezium MongoDB 连接器记录流 4.7. Debezium MongoDB 连接器如何处理错误和问题 5. MySQL 的 Debezium 连接器 Expand section "5. MySQL 的 Debezium 连接器" Collapse section "5. MySQL 的 Debezium 连接器" 5.1. Debezium MySQL 连接器的工作方式 Expand section "5.1. Debezium MySQL 连接器的工作方式" Collapse section "5.1. Debezium MySQL 连接器的工作方式" 5.1.1. Debezium 连接器支持的 MySQL 拓扑 5.1.2. Debezium MySQL 连接器如何处理数据库架构更改 5.1.3. Debezium MySQL 连接器如何公开数据库架构更改 5.1.4. Debezium MySQL 连接器如何执行数据库快照 Expand section "5.1.4. Debezium MySQL 连接器如何执行数据库快照" Collapse section "5.1.4. Debezium MySQL 连接器如何执行数据库快照" 5.1.4.1. 临时快照 5.1.4.2. 增量快照 5.1.4.3. 触发增量快照 5.1.4.4. 停止增量快照 5.1.5. 接收 Debezium MySQL 更改事件记录的 Kafka 主题默认名称 5.2. Debezium MySQL 连接器数据更改事件的描述 Expand section "5.2. Debezium MySQL 连接器数据更改事件的描述" Collapse section "5.2. Debezium MySQL 连接器数据更改事件的描述" 5.2.1. 关于 Debezium MySQL 中的键更改事件 5.2.2. 关于 Debezium MySQL 更改事件中的值 5.3. Debezium MySQL 连接器如何映射数据类型 5.4. 设置 MySQL 以运行 Debezium 连接器 Expand section "5.4. 设置 MySQL 以运行 Debezium 连接器" Collapse section "5.4. 设置 MySQL 以运行 Debezium 连接器" 5.4.1. 为 Debezium 连接器创建 MySQL 用户 5.4.2. 为 Debezium 启用 MySQL binlog 5.4.3. 为 Debezium 启用 MySQL 全局事务标识符 5.4.4. 为 Debezium 配置 MySQL 会话超时 5.4.5. 为 Debezium MySQL 连接器启用查询日志事件 5.4.6. 为 Debezium MySQL 连接器验证 binlog 行值选项 5.5. 部署 Debezium MySQL 连接器 Expand section "5.5. 部署 Debezium MySQL 连接器" Collapse section "5.5. 部署 Debezium MySQL 连接器" 5.5.1. 使用 AMQ Streams 部署 MySQL 连接器 5.5.2. 使用 AMQ Streams 部署 Debezium MySQL 连接器 5.5.3. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium MySQL 连接器 5.5.4. 验证 Debezium MySQL 连接器是否正在运行 5.5.5. Debezium MySQL 连接器配置属性的描述 5.6. 监控 Debezium MySQL 连接器性能 Expand section "5.6. 监控 Debezium MySQL 连接器性能" Collapse section "5.6. 监控 Debezium MySQL 连接器性能" 5.6.1. 在 MySQL 数据库的快照期间监控 Debezium 5.6.2. 监控 Debezium MySQL 连接器记录流 5.6.3. 监控 Debezium MySQL 连接器模式历史记录 5.7. Debezium MySQL 连接器如何处理错误和问题 6. Oracle 的 Debezium Connector Expand section "6. Oracle 的 Debezium Connector" Collapse section "6. Oracle 的 Debezium Connector" 6.1. Debezium Oracle 连接器如何工作 Expand section "6.1. Debezium Oracle 连接器如何工作" Collapse section "6.1. Debezium Oracle 连接器如何工作" 6.1.1. Debezium Oracle 连接器如何执行数据库快照 Expand section "6.1.1. Debezium Oracle 连接器如何执行数据库快照" Collapse section "6.1.1. Debezium Oracle 连接器如何执行数据库快照" 6.1.1.1. 临时快照 6.1.1.2. 增量快照 6.1.1.3. 触发增量快照 6.1.1.4. 停止增量快照 6.1.2. 接收 Debezium Oracle 更改事件记录的 Kafka 主题默认名称 6.1.3. Debezium Oracle 连接器如何公开数据库 schema 的变化 6.1.4. Debezium Oracle 连接器生成的事件代表事务边界 Expand section "6.1.4. Debezium Oracle 连接器生成的事件代表事务边界" Collapse section "6.1.4. Debezium Oracle 连接器生成的事件代表事务边界" 6.1.4.1. Debezium Oracle 连接器如何通过事务元数据增强更改事件信息 6.1.5. Debezium Oracle 连接器如何使用事件缓冲 6.1.6. Debezium Oracle 连接器如何检测 SCN 值中的差距 6.1.7. Debezium 如何管理数据库中不经常更改的偏移量 6.2. Debezium Oracle 连接器数据更改事件的描述 Expand section "6.2. Debezium Oracle 连接器数据更改事件的描述" Collapse section "6.2. Debezium Oracle 连接器数据更改事件的描述" 6.2.1. 关于 Debezium Oracle 连接器更改事件中的键 6.2.2. 关于 Debezium Oracle 连接器更改事件中的值 6.3. Debezium Oracle 连接器如何映射数据类型 6.4. 设置 Oracle 以使用 Debezium Expand section "6.4. 设置 Oracle 以使用 Debezium" Collapse section "6.4. 设置 Oracle 以使用 Debezium" 6.4.1. Debezium Oracle 连接器与 Oracle 安装类型的兼容性 6.4.2. 在捕获更改事件时 Debezium Oracle 连接器排除的模式 6.4.3. 在捕获更改事件时 Debezium Oracle 连接器排除的表 6.4.4. 准备 Oracle 数据库以用于 Debezium 6.4.5. 调整 Oracle redo 日志的大小,以适应数据字典 6.4.6. 为 Debezium Oracle 连接器创建 Oracle 用户 6.4.7. 支持 Oracle 备用数据库 6.5. 部署 Debezium Oracle 连接器 Expand section "6.5. 部署 Debezium Oracle 连接器" Collapse section "6.5. 部署 Debezium Oracle 连接器" 6.5.1. 获取 Oracle JDBC 驱动程序 6.5.2. 使用 AMQ Streams 部署 Debezium Oracle 连接器 6.5.3. 使用 AMQ Streams 部署 Debezium Oracle 连接器 6.5.4. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium Oracle 连接器 6.5.5. 配置容器数据库和非容器数据库 6.5.6. 验证 Debezium Oracle 连接器是否正在运行 6.6. Debezium Oracle 连接器配置属性的描述 6.7. 监控 Debezium Oracle 连接器性能 Expand section "6.7. 监控 Debezium Oracle 连接器性能" Collapse section "6.7. 监控 Debezium Oracle 连接器性能" 6.7.1. Debezium Oracle 连接器快照指标 6.7.2. Debezium Oracle 连接器流指标 6.7.3. Debezium Oracle 连接器模式历史记录指标 6.8. Oracle 连接器常见问题 7. PostgreSQL 的 Debezium 连接器 Expand section "7. PostgreSQL 的 Debezium 连接器" Collapse section "7. PostgreSQL 的 Debezium 连接器" 7.1. Debezium PostgreSQL 连接器概述 7.2. Debezium PostgreSQL 连接器的工作方式 Expand section "7.2. Debezium PostgreSQL 连接器的工作方式" Collapse section "7.2. Debezium PostgreSQL 连接器的工作方式" 7.2.1. PostgreSQL 连接器的安全性 7.2.2. Debezium PostgreSQL 连接器如何执行数据库快照 Expand section "7.2.2. Debezium PostgreSQL 连接器如何执行数据库快照" Collapse section "7.2.2. Debezium PostgreSQL 连接器如何执行数据库快照" 7.2.2.1. 临时快照 7.2.2.2. 增量快照 7.2.2.3. 触发增量快照 7.2.2.4. 停止增量快照 7.2.3. Debezium PostgreSQL 连接器流更改事件记录 7.2.4. 接收 Debezium PostgreSQL 更改事件记录的 Kafka 主题默认名称 7.2.5. Debezium PostgreSQL 连接器生成的事件代表事务边界 7.3. Debezium PostgreSQL 连接器数据更改事件的描述 Expand section "7.3. Debezium PostgreSQL 连接器数据更改事件的描述" Collapse section "7.3. Debezium PostgreSQL 连接器数据更改事件的描述" 7.3.1. 关于 Debezium PostgreSQL 更改事件中的键 7.3.2. 关于 Debezium PostgreSQL 更改事件中的值 7.4. Debezium PostgreSQL 连接器如何映射数据类型 7.5. 设置 PostgreSQL 以运行 Debezium 连接器 Expand section "7.5. 设置 PostgreSQL 以运行 Debezium 连接器" Collapse section "7.5. 设置 PostgreSQL 以运行 Debezium 连接器" 7.5.1. 为 Debezium pgoutput 插件配置复制插槽 7.5.2. 为 Debezium 连接器设置 PostgreSQL 权限 7.5.3. 设置特权,使 Debezium 能够创建 PostgreSQL 出版物 7.5.4. 配置 PostgreSQL 以允许使用 Debezium 连接器主机复制 7.5.5. 配置 PostgreSQL 来管理 Debezium WAL 磁盘空间消耗 7.6. 部署 Debezium PostgreSQL 连接器 Expand section "7.6. 部署 Debezium PostgreSQL 连接器" Collapse section "7.6. 部署 Debezium PostgreSQL 连接器" 7.6.1. 使用 AMQ Streams 部署 PostgreSQL 连接器 7.6.2. 使用 AMQ Streams 部署 Debezium PostgreSQL 连接器 7.6.3. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium PostgreSQL 连接器 7.6.4. 验证 Debezium PostgreSQL 连接器是否正在运行 7.6.5. Debezium PostgreSQL 连接器配置属性的描述 7.7. 监控 Debezium PostgreSQL 连接器性能 Expand section "7.7. 监控 Debezium PostgreSQL 连接器性能" Collapse section "7.7. 监控 Debezium PostgreSQL 连接器性能" 7.7.1. 在 PostgreSQL 数据库的快照期间监控 Debezium 7.7.2. 监控 Debezium PostgreSQL 连接器记录流 7.8. Debezium PostgreSQL 连接器如何处理错误和问题 8. SQL Server 的 Debezium 连接器 Expand section "8. SQL Server 的 Debezium 连接器" Collapse section "8. SQL Server 的 Debezium 连接器" 8.1. Debezium SQL Server 连接器概述 8.2. Debezium SQL Server 连接器如何工作 Expand section "8.2. Debezium SQL Server 连接器如何工作" Collapse section "8.2. Debezium SQL Server 连接器如何工作" 8.2.1. Debezium SQL Server 连接器如何执行数据库快照 Expand section "8.2.1. Debezium SQL Server 连接器如何执行数据库快照" Collapse section "8.2.1. Debezium SQL Server 连接器如何执行数据库快照" 8.2.1.1. 临时快照 8.2.1.2. 增量快照 8.2.1.3. 触发增量快照 8.2.1.4. 停止增量快照 8.2.2. Debezium SQL Server 连接器如何读取更改数据表 8.2.3. 数据库中没有记录的最大 LSN 8.2.4. Debezium SQL Server 连接器的限制 8.2.5. 接收 Debezium SQL Server 更改事件记录的 Kafka 主题默认名称 8.2.6. Debezium SQL Server 连接器如何使用 schema 更改主题 8.2.7. Debezium SQL Server 连接器数据更改事件的描述 Expand section "8.2.7. Debezium SQL Server 连接器数据更改事件的描述" Collapse section "8.2.7. Debezium SQL Server 连接器数据更改事件的描述" 8.2.7.1. 关于 Debezium SQL Server 中的键更改事件 8.2.7.2. 关于 Debezium SQL Server 更改事件中的值 8.2.8. Debezium SQL Server 连接器生成的事件代表事务边界 Expand section "8.2.8. Debezium SQL Server 连接器生成的事件代表事务边界" Collapse section "8.2.8. Debezium SQL Server 连接器生成的事件代表事务边界" 8.2.8.1. 更改数据事件增强 8.2.9. Debezium SQL Server 连接器如何映射数据类型 8.3. 设置 SQL Server 以运行 Debezium 连接器 Expand section "8.3. 设置 SQL Server 以运行 Debezium 连接器" Collapse section "8.3. 设置 SQL Server 以运行 Debezium 连接器" 8.3.1. 在 SQL Server 数据库中启用 CDC 8.3.2. 在 SQL Server 表中启用 CDC 8.3.3. 验证用户有权访问 CDC 表 8.3.4. Azure 上的 SQL Server 8.3.5. SQL Server 捕获作业代理配置对服务器负载和延迟的影响 8.3.6. SQL Server 捕获作业代理配置参数 8.4. 部署 Debezium SQL Server 连接器 Expand section "8.4. 部署 Debezium SQL Server 连接器" Collapse section "8.4. 部署 Debezium SQL Server 连接器" 8.4.1. 使用 AMQ Streams 部署 SQL Server 连接器 8.4.2. 使用 AMQ Streams 部署 Debezium SQL Server 连接器 8.4.3. 通过从 Dockerfile 构建自定义 Kafka Connect 容器镜像来部署 Debezium SQL Server 连接器 8.4.4. Debezium SQL Server 连接器配置属性的描述 8.5. 在模式更改后刷新捕获表 Expand section "8.5. 在模式更改后刷新捕获表" Collapse section "8.5. 在模式更改后刷新捕获表" 8.5.1. 模式更改后运行离线更新 8.5.2. 架构更改后运行在线更新 8.6. 监控 Debezium SQL Server 连接器性能 Expand section "8.6. 监控 Debezium SQL Server 连接器性能" Collapse section "8.6. 监控 Debezium SQL Server 连接器性能" 8.6.1. Debezium SQL Server 连接器快照指标 8.6.2. Debezium SQL Server 连接器流指标 8.6.3. Debezium SQL Server 连接器模式历史记录指标 9. 监控 Debezium Expand section "9. 监控 Debezium" Collapse section "9. 监控 Debezium" 9.1. 用于监控 Debezium 连接器的指标 9.2. 在本地安装中启用 JMX Expand section "9.2. 在本地安装中启用 JMX" Collapse section "9.2. 在本地安装中启用 JMX" 9.2.1. ZooKeeper JMX 环境变量 9.2.2. Kafka JMX 环境变量 9.2.3. Kafka Connect JMX 环境变量 9.3. 监控 OpenShift 上的 Debezium 10. Debezium 日志记录 Expand section "10. Debezium 日志记录" Collapse section "10. Debezium 日志记录" 10.1. Debezium 日志记录概念 10.2. 默认 Debezium 日志记录配置 10.3. 配置 Debezium 日志记录 Expand section "10.3. 配置 Debezium 日志记录" Collapse section "10.3. 配置 Debezium 日志记录" 10.3.1. 通过配置日志记录器来更改 Debezium 日志记录级别 10.3.2. 使用 Kafka Connect API 动态更改 Debezium 日志记录级别 10.3.3. 通过添加映射的诊断上下文来更改 Debezium 日志记录级别 10.4. OpenShift 中的 Debezium 日志记录 11. 为应用程序配置 Debezium 连接器 Expand section "11. 为应用程序配置 Debezium 连接器" Collapse section "11. 为应用程序配置 Debezium 连接器" 11.1. 自定义 Kafka Connect 自动主题创建 Expand section "11.1. 自定义 Kafka Connect 自动主题创建" Collapse section "11.1. 自定义 Kafka Connect 自动主题创建" 11.1.1. 为 Kafka 代理禁用自动主题创建 11.1.2. 在 Kafka Connect 中配置自动主题创建 11.1.3. 配置自动创建的主题 Expand section "11.1.3. 配置自动创建的主题" Collapse section "11.1.3. 配置自动创建的主题" 11.1.3.1. 主题创建组 11.1.3.2. 主题创建组配置属性 11.1.3.3. 指定 Debezium 默认主题创建组的配置 11.1.3.4. 指定 Debezium 自定义主题创建组的配置 11.1.3.5. 注册 Debezium 自定义主题创建组 11.2. 配置 Debezium 连接器以使用 Avro 序列化 Expand section "11.2. 配置 Debezium 连接器以使用 Avro 序列化" Collapse section "11.2. 配置 Debezium 连接器以使用 Avro 序列化" 11.2.1. 关于 Service Registry 11.2.2. 部署使用 Avro 序列化的 Debezium 连接器概述 11.2.3. 在 Debezium 容器中部署使用 Avro 的连接器 11.2.4. 关于 Avro 名称要求 11.3. 以 CloudEvents 格式发送 Debezium 更改事件记录 Expand section "11.3. 以 CloudEvents 格式发送 Debezium 更改事件记录" Collapse section "11.3. 以 CloudEvents 格式发送 Debezium 更改事件记录" 11.3.1. CloudEvents 格式的 Debezium 更改事件记录示例 11.3.2. 配置 Debezium CloudEvents converter 的示例 11.3.3. Debezium CloudEvents converter 配置选项 11.4. 将信号发送到 Debezium 连接器 Expand section "11.4. 将信号发送到 Debezium 连接器" Collapse section "11.4. 将信号发送到 Debezium 连接器" 11.4.1. 启用 Debezium 信号 Expand section "11.4.1. 启用 Debezium 信号" Collapse section "11.4.1. 启用 Debezium 信号" 11.4.1.1. Debezium 信号数据收集所需的结构 11.4.1.2. 创建 Debezium 信号数据收集 11.4.2. Debezium 信号操作的类型 Expand section "11.4.2. Debezium 信号操作的类型" Collapse section "11.4.2. Debezium 信号操作的类型" 11.4.2.1. 日志记录信号 11.4.2.2. 临时快照信号 11.4.2.3. 增量快照 12. 应用转换以修改使用 Apache Kafka 交换的消息 Expand section "12. 应用转换以修改使用 Apache Kafka 交换的消息" Collapse section "12. 应用转换以修改使用 Apache Kafka 交换的消息" 12.1. 使用 SMT predicates 有选择地应用转换 Expand section "12.1. 使用 SMT predicates 有选择地应用转换" Collapse section "12.1. 使用 SMT predicates 有选择地应用转换" 12.1.1. 关于 SMT predicates 12.1.2. 定义 SMT predicates 12.1.3. 忽略 tombstone 事件 12.2. 将 Debezium 事件记录路由到您指定的主题 Expand section "12.2. 将 Debezium 事件记录路由到您指定的主题" Collapse section "12.2. 将 Debezium 事件记录路由到您指定的主题" 12.2.1. 将 Debezium 记录路由到您指定的主题的用例 12.2.2. 将多个表的 Debezium 记录路由到一个主题的示例 12.2.3. 确保 Debezium 记录中的唯一键路由到同一主题 12.2.4. 用于有选择地应用主题路由转换的选项 12.2.5. 用于配置 Debezium 主题路由转换的选项 12.3. 根据事件内容将更改事件记录路由到主题 Expand section "12.3. 根据事件内容将更改事件记录路由到主题" Collapse section "12.3. 根据事件内容将更改事件记录路由到主题" 12.3.1. 设置 Debezium 基于 content-routing SMT 12.3.2. 示例: Debezium 基本基于内容的路由配置 12.3.3. 在 Debezium 内容的路由表达式中使用的变量 12.3.4. 用于有选择地应用基于内容的路由转换的选项 12.3.5. 为其他脚本语言配置基于内容的路由条件 12.3.6. 配置基于内容的路由转换的选项 12.4. 过滤 Debezium 更改事件记录 Expand section "12.4. 过滤 Debezium 更改事件记录" Collapse section "12.4. 过滤 Debezium 更改事件记录" 12.4.1. 设置 Debezium 过滤器 SMT 12.4.2. 示例: Debezium 基本过滤器 SMT 配置 12.4.3. 在过滤器表达式中使用的变量 12.4.4. 用于有选择地应用过滤器转换的选项 12.4.5. 为其他脚本语言过滤条件配置 12.4.6. 配置过滤器转换的选项 12.5. 从 Debezium 更改事件中提取源记录 after 状态 Expand section "12.5. 从 Debezium 更改事件中提取源记录 after 状态" Collapse section "12.5. 从 Debezium 更改事件中提取源记录 after 状态" 12.5.1. Debezium 更改事件结构的描述 12.5.2. Debezium 事件扁平化转换的行为 12.5.3. 配置 Debezium 事件扁平化转换 12.5.4. 在 Kafka 记录中添加 Debezium 元数据的示例 12.5.5. 用于有选择地应用事件扁平化转换的选项 12.5.6. 配置 Debezium 事件扁平化转换的选项 12.6. 从 Debezium MongoDB 更改事件中提取源文档 Expand section "12.6. 从 Debezium MongoDB 更改事件中提取源文档 " Collapse section "12.6. 从 Debezium MongoDB 更改事件中提取源文档 " 12.6.1. Debezium MongoDB 更改事件结构的描述 12.6.2. Debezium MongoDB 事件扁平化转换的行为 12.6.3. 配置 Debezium MongoDB 事件扁平化转换 Expand section "12.6.3. 配置 Debezium MongoDB 事件扁平化转换" Collapse section "12.6.3. 配置 Debezium MongoDB 事件扁平化转换" 12.6.3.1. 示例: Debezium MongoDB 事件扁平化的基本配置 12.6.4. MongoDB 事件消息中编码数组的选项 12.6.5. 在 MongoDB 事件消息中扁平化嵌套结构 12.6.6. Debezium MongoDB 连接器如何报告 $unset 操作删除的字段名称 12.6.7. 确定原始数据库操作的类型 12.6.8. 使用 MongoDB 事件扁平化 SMT 将 Debezium 元数据添加到 Kafka 记录 12.6.9. 应用 MongoDB 的选项有选择地提取新的文档状态转换 12.6.10. MongoDB 事件扁平化转换的配置选项 12.7. 配置 Debezium 连接器以使用 outbox 模式 Expand section "12.7. 配置 Debezium 连接器以使用 outbox 模式" Collapse section "12.7. 配置 Debezium 连接器以使用 outbox 模式" 12.7.1. Debezium outbox 消息示例 12.7.2. Debezium outbox 事件路由器 SMT 期望的 outbox 表结构 12.7.3. 基本 Debezium outbox 事件路由器 SMT 配置 12.7.4. 用于有选择地应用 Outbox 事件路由器转换的选项 12.7.5. 在 Debezium outbox 消息中使用 Avro 作为有效负载格式 12.7.6. 在 Debezium outbox 信息中记录其他字段 12.7.7. 将转义的 JSON 字符串扩展为 JSON 12.7.8. 配置开箱即用事件路由器转换的选项 12.8. 配置 Debezium MongoDB 连接器以使用 outbox 模式 Expand section "12.8. 配置 Debezium MongoDB 连接器以使用 outbox 模式" Collapse section "12.8. 配置 Debezium MongoDB 连接器以使用 outbox 模式" 12.8.1. Debezium MongoDB outbox 消息示例 12.8.2. Debezium mongodb outbox 事件路由器 SMT 期望的 outbox 集合结构 12.8.3. 基本 Debezium MongoDB outbox 事件路由器 SMT 配置 12.8.4. 用于有选择地应用 MongoDB outbox 事件路由器转换的选项 12.8.5. 在 Debezium MongoDB outbox 消息中使用 Avro 作为有效负载格式 12.8.6. 在 Debezium MongoDB outbox 信息中记录其他字段 12.8.7. 将转义的 JSON 字符串扩展为 JSON 12.8.8. 配置开箱即用事件路由器转换的选项 13. 开发 Debezium 自定义数据类型转换器 Expand section "13. 开发 Debezium 自定义数据类型转换器" Collapse section "13. 开发 Debezium 自定义数据类型转换器" 13.1. 创建 Debezium 自定义数据类型转换器 Expand section "13.1. 创建 Debezium 自定义数据类型转换器" Collapse section "13.1. 创建 Debezium 自定义数据类型转换器" 13.1.1. Debezium 自定义转换器示例 13.1.2. Debezium 和 Kafka Connect API 模块依赖项 13.2. 使用带有 Debezium 连接器的自定义转换器 Expand section "13.2. 使用带有 Debezium 连接器的自定义转换器" Collapse section "13.2. 使用带有 Debezium 连接器的自定义转换器" 13.2.1. 部署自定义转换器 13.2.2. 将连接器配置为使用自定义转换器 法律通告 Settings Close Language: 简体中文 日本語 English Language: 简体中文 日本語 English Format: Multi-page Single-page Format: Multi-page Single-page Language and Page Formatting Options Language: 简体中文 日本語 English Language: 简体中文 日本語 English Format: Multi-page Single-page Format: Multi-page Single-page Debezium 用户指南 Red Hat Integration 2023.q2用于 Red Hat Integration 2.1.4 Red Hat Integration Documentation Team fuse-docs-support@redhat.com 法律通告摘要 本指南论述了如何使用由红帽集成提供的连接器。 Next