当前位置: 首页 > 知识库问答 >
问题:

将表添加到debezium连接器

邵胜涝
2023-03-14

我有一个Debezium连接器,连接到SQL服务器,其中一个表在table.include.list配置参数中。我想添加另一个表,我已经添加到table.include.list参数中,尽管我的连接器没有接收到它。

我以前的table.include.list看起来像这样:
"table.include.list":"dbo。用户"

我当前的表格。包括列表如下所示:
“table.include.list”:“dbo.Users,dbo.charlie”

我重启了Kafka,重启了Debezium中的连接器,但是当我查看bash中的连接器状态时,我仍然看到旧的table.include.list值。是否需要做其他事情来让连接器刷新配置文件中的内容?

Debezium版本:1.2.5。Kafka最终版本:2.7.0

共有1个答案

杨良平
2023-03-14

重新启动连接器将无法获得最新配置,您必须使用新配置重新部署(发布)连接器。

 类似资料:
  • 向Postgres连接器中添加新表的步骤应该是什么?我的连接器正在跟踪两个表(表1和表2),我想添加另一个表(表3),它已经存在,并且在我的数据库中有数据。 这是我当前的配置: } 我试图修改连接器“table.include.list”并将“public.table3”添加到列表中,但它似乎没有触发此表的快照过程。 有什么想法吗?

  • 目标: 需要向现有的Debezium MySQL连接器版本1.1.1添加一个新表。最终的连接器重新启动后,应使用更新的配置(table.whitelist中的新表)将表中的数据填充到主题中。 问题: 没有明确的策略来添加一个新表,该表将在初始快照完成后(连接器的前一个版本正在工作)与其数据一起添加到Kafka中。我们正在寻找类似于snapshot.select.statement.override

  • 我已经将 Kafka-connect-jdbc-5.5.0.jar 文件从 Confluent 下载到我的本地机器中,我想知道一种将此 jar 添加到 plugin.path=/kafka/connect 的方法。我正在尝试将数据接收器到 MySQL 服务器,所以我使用“连接器.class”:“io.confluent.connect.jdbc.JdbcSinkConnector”,但我面临“er

  • 下面是/etc/kafka/connect-MongoDB-source.properties中的MongoDB配置 但是低于误差 以独立模式运行连接器。 我在debezium-debezium-连接器-mongob-1.0.0/debezium-connector-mongodb-1.0.0.Final.jar 类路径的设置如下 使用插件路径,我看到它能够注册和加载所有必需的插件。 但最后还是同

  • 我有一个现有的2个kafka服务器加载了mysql连接器。它起作用了。此外,我需要添加MongoDB连接器。我已经在我的Kafka服务器(Centos7)上安装了confluent schema registry,它可以工作,我停止/启动/重新启动,看起来没有什么问题。我在这里下载并提取了debezium Mongo插件/usr/连接器/插件/debezium连接器mongodb/ 我编辑了 /e

  • 当我在启用CDC功能后尝试将Debezium连接到SQL Server数据库时,我收到以下错误消息: 以下是我的连接器配置: 我在这里找到了一个解决办法: https://github.com/Microsoft/mssql-jdbc/issues/879#issuecomment-438825486 但有可能将其应用于debezium连接器吗?Debezium是否与Sql Server 2008