在 Debezium Mysql Connector 中将更多表列入白名单的有效方法

2024-02-19

将新表列入 debezium mysql 连接器白名单是否遵循任何最佳实践?

我们在 CDC 流程中使用 debezium mysql 连接器,并且出现了一个用例,将更多表列入连接器配置的白名单。以下是正在使用的 Debezium 的版本详细信息以及

{
    "class": "io.debezium.connector.mysql.MySqlConnector",
    "version": "0.8.0.Final",
    "snapshot.mode": "schema_only"
}

有一张 Debezium 票https://issues.redhat.com/browse/DBZ-906 https://issues.redhat.com/browse/DBZ-906表示运行连接器

"snapshot.mode": "schema_only_recover"

模式并在重新启动连接器之前重新创建历史主题。我对这种方法有几个问题

  • 此选项也适用于上述版本吗?
  • 如何获取在将表列入白名单之前对新表进行的更新?

  • 首先,请升级 Debezium,因为 0.8.0 版本非常旧。

    一般来说,有多种方法可以解决您的问题,但如果您可以承受流式传输的暂停,那么我建议您这样做 1)停止当前连接器 2) 使用列入白名单的新表启动一个新连接器以在其上执行快照 3) 快照完成后,使用更新的白名单列表启动原始连接器

    参见示例https://groups.google.com/forum/?fromgroups=#!msg/debezium/Iw4BgLZ8Mq4/SZBLGwEaAQAJ;context-place=forum/debezium https://groups.google.com/forum/?fromgroups=#!msg/debezium/Iw4BgLZ8Mq4/SZBLGwEaAQAJ;context-place=forum/debezium详细信息

    如果您无法承受停机时间,请检查中介绍的实验方法DBZ-175 https://issues.redhat.com/browse/DBZ-175

    本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

    在 Debezium Mysql Connector 中将更多表列入白名单的有效方法 的相关文章

    随机推荐

    • Sublime Text 3 有集成终端吗?

      我通常使用 WebStorm IDE 进行 Node js 和 FE JavaScript 开发 然而 我正在考虑使用 Sublime Text 3 因为我在蹩脚的旧 Macbook Pro 上的计算能力已经耗尽 而 ST3 在内存和 CP
    • 调用函数时设置列名

      假设我们有一个数字 data framefoo并想要找到每两列的总和 foo lt data frame x 1 5 y 4 8 z 10 14 w 8 4 bar lt combn colnames foo 2 function x fo
    • 詹金斯附件-语法是什么?

      我试图让 Jenkins 将一个或一组文件附加到作业已完成的电子邮件通知中 我不断收到以下错误 发送电子邮件以触发 成功 错误 访问要附加的文件时出错 需要 Ant GLOB 模式 但看到了C p p etc html See Filese
    • 设置多线程调试 (/MTd) 时发生崩溃 (C++)

      在构建动态库 C 时 我们可以选择Windows的多线程调试 MTd 或多线程调试DLL MDd 运行时库 如果我们选择多线程调试 那么创建的动态库将负责库中使用的所有变量的内存分配 因此 以下示例将显示 MDd 设置有效而 MTd 设置失
    • WindowsError:[错误2]系统找不到指定的文件,无法在Python中解析

      我制作了一个 Python 程序 它将清理我下载的 torrent 文件和文件夹中存在的不必要的名称 以便我可以将其上传到我的无限 Google Drive 存储帐户 而无需太多麻烦 然而 它给了我 WindowsError Error 2
    • Spring Security,注销:将参数从/logout传递到/login

      我使用默认的 Spring Security 来处理注销 登录 我有一个控制器方法来处理 login 当我注销时 我看到 Spring Security 将我重定向到app login logout 这个 Spring 创建的参数的存在 有
    • Android Phonegap 滑动类型

      我正在 Android Phonegap 中开发一个应用程序 我需要在我的应用程序中应用 swype 如何申请 任何人都好心指导我 您可以使用 jGestures jQuery 库 http jgestures codeplex com j
    • 核心数据 - 使用谓词过滤一对多关系

      我的核心数据模型中有以下两个实体 Manufacture name other attributes Product name other attributes 我已经设置了一对多关系 Manufacturer manufactures l
    • Postman请求带body表单数据转json

      我和邮递员有问题 For one side I can make this request with the body in form data 但是 当我尝试使用 raw json 中的正文发送相同的请求时 我得到了 我正在尝试通过 An
    • 为什么 javascript 不在加载 Ext.Ajax.Request 的 .php 文件中执行?

      我想通过 ajax 加载 php 文件 该文件在加载时执行 ExtJS 脚本 从而修改 DOM 中已存在的现有 ExtJS 对象 但是 我什至无法从正在加载的页面执行 JavascriptExt Ajax request Firebug N
    • 如何通过代码编程获取设备的 IMEI/ESN 号码但在 android > 6 中

      我的安卓版本是棉花糖6 0 如何以编程方式在 android gt 6 中查找 获取 imei 号码 注意 我在 AndroidManifest xml 文件中添加了 READ PHONE STATE 权限
    • Laravel - 会话返回 null

      我第一次在 Laravel 中使用会话 并且尝试执行多步骤形式 所以我认为使用会话将是一个明智之举 但是下面的代码返回一个空值 我做错了什么 user information name gt request gt name email gt
    • 扩展 CodeIgniter 中的控制器类

      I have class MY Controller extends CI Controller和大配置文件部分的通用逻辑 所以我尝试创建class Profile extends MY Controller正如我所理解的那样 配置文件部分
    • 如何使用自定义元素将子自定义元素包装到 div 中

      我正在尝试创建一个包装器自定义元素 将其子自定义元素包装到 div 中 但子元素没有被包装 相反 一个空的 div 被插入到子元素之前的包装元素中
    • 如何对私有变量进行单元测试?

      考虑一个链表类 我维护 2 个私有变量 1 firstNode 和 2 lastNode 因此 这些变量仅供内部使用 不通过 getter 公开 我想测试操作是否按预期修改这两个变量 例如 如果最后一个节点是重复的 则消除排序链表中的重复应
    • Blade 文件中的 if else 条件(laravel 5.3)

      我想检查一下if else我的刀片文件中的状况 我想检查一下情况 user gt status waiting 如下面给出的代码 输出按我的预期正确返回 但随着我的输出 我发现打印了大括号 我想删除结果中的大括号 我的有什么问题吗if健康
    • 计时器每 5 分钟运行一次

      如何每 5 分钟运行一些函数 示例 我想跑步sendRequest 仅在 14 00 14 05 14 10 等时间 我想用 C 以编程方式完成它 该应用程序是 Windows 服务 Use System Threading Timer h
    • Mockito:模拟对象,不是成员,但内联创建

      我有一个类执行以下操作 public class Transformer public void transform final Car car throws IOException switch car getType case OFFR
    • 如何以 vmware 清晰度动态切换主题

      Vmware Clarity 0 10 16 刚刚发布了新的深色主题 这很棒 他们描述了如何添加新主题 但没有描述在页面内动态更改它的可能性 是因为不可行吗 如果是的话 我该如何使用 Angular 4 来做到这一点 有什么网站可以帮助我解
    • 在 Debezium Mysql Connector 中将更多表列入白名单的有效方法

      将新表列入 debezium mysql 连接器白名单是否遵循任何最佳实践 我们在 CDC 流程中使用 debezium mysql 连接器 并且出现了一个用例 将更多表列入连接器配置的白名单 以下是正在使用的 Debezium 的版本详细