我使用postgres配置了debezium，如下代码所示，当我启动我的spring引导应用程序时，a get an error Creation of replication slot failed' with config: {name=student-postgres-connector, connector.class=io.debezium.connector.postgresql.PostgresConnector(PostgresConnectorTask.java:134) ~[
浏览 902提问于2021-04-02得票数 5
我有一个RDS多AZ postgres数据库(主-备用)，我正在调查Debezium以流到Kafka的更改。
我正在阅读关于万一故障转移可能出错的文档：，它看起来是一个非常可怕的场景。从我通过使用故障转移重新启动所做的一些测试来看，当端点从主节点更改为备用时，Debezium连接器继续工作，并在备用服务器上自动创建一个复制槽。但据我所知，除非您能够确保在写入新数据之前创建新主服务器(旧备用)上的复制槽，否则无法保证不
浏览 2提问于2021-10-01得票数 3
回答已采纳
我有一个应用程序，它使用debezium-postgres连接器从postgres发布kafka上的事件。如果重新创建kubernetes部署策略，应用程序将正常工作。但在使用RollingUpdate部署策略时抛出异常
异常replication slot "XXX" is active for PID XXX与旧的pod一样使用相同的复制槽。应用程序正在使用PGOUTPUT debez
浏览 0提问于2021-02-03得票数 1
在一个Postgres服务器实例中，每个服务器都有自己的数据库(分别为db_a和db_b )(这只是一个暂存环境，因此我们没有集群)。那么，为什么不能使用多个Debezium引擎来侦听单个Postgres服务器中的多个数据库呢？我所缺少的here?Another替代方案是只使用一个Debezium引擎来侦听Postgres服务器实例中的所有数据库，但显然它在配置中需要database.dbname，所以我想首选的方法是为每个数据库定义一个新的Debezium</
浏览 6提问于2021-09-02得票数 1
回答已采纳
1回答
复制槽已存在
、、
每当我重启debezium kafka-connect容器，或者部署另一个实例时，我都会得到以下错误： at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initReplicationSlot(Postg
浏览 0提问于2018-06-08得票数 6
Google最终添加了对Cloudsql postgresql逻辑复制/解码支持的支持。我尝试做的是使用Debezium捕获数据库表上的更改，然后将更改以json形式发布到Gcp pubsub。我正在使用Debezium服务器和Gcp Pubsub Sink，只是为了验证连接是否正常工作，但一直收到以下错误消息org.postgresql.util.PSQLException: ERROR:根据这个文档，我使用的是DATABASE_SOURCE_PLUGIN_NAME。valu
浏览 2提问于2021-06-04得票数 2
我正在尝试并设置一个复制用户。我创建复制用户的步骤如下：
ALTER TABLE person OWNER TO replication_group| {replication
浏览 26提问于2022-07-09得票数 0
由卡夫卡连接器创建的复制插槽正在填满。rds.logical_replication: 1"database.port" = "myport"
"databas
浏览 4提问于2020-03-16得票数 4
回答已采纳
我在Debezium连接器配置中找不到有关快照事件(具有__op=r的事件)的source.lsn字段值的信息。由于我的db没有太多的负载，所以我假设从一开始创建的所有WAL段仍然存在，尽管不确定。我的问题如下：
如果debezium只是通过对所有现有数据发出select查询来获取该记录的信息，那么它如何获得快照记录的非空select值(与检查WAL以生成具有__op=c、__op=u或__op是否有来自Debezium的文档描述在快照情况下可能的lsn值？
浏览 9提问于2022-01-13得票数 0
我在Debezium文档中发现了这个限制：
PostgreSQL 9.6只支持主服务器上的逻辑复制槽。这意味着PostgreSQL集群中的副本不能配置为逻辑复制，因此Debezium PostgreSQL连接器只能与主服务器连接和通信。可以在PostgreSQL从站中使用Debezium的版本：10.x和11.x
浏览 3提问于2019-01-25得票数 3
我使用Postgresql 14，它是为逻辑复制设置的。尝试用debezium版本1.8来流更改。实际上，一切看起来都还好。根据这的好答案，这种更新会创建一个WAL记录，但实际上它是否试图复制而不是发布呢？更改将传播到复制槽。
浏览 0提问于2022-02-02得票数 0
回答已采纳
# Download, unpack, and place the debezium-connector-postgres folder into the /opt/kafka/plugins/debeziumdirectory
RUN curl -s https://repo1.maven.org/maven2/io/debezium/debezium-connector-postgres</em
浏览 8提问于2021-10-23得票数 5
回答已采纳
在使用AWS数据迁移服务时，我会遇到以下错误。Source -一个postgres rds实例，其中包含多个数据库(80 GB)表数-包括所有数据库的表总数约为200个我创建了四个任务，用于将四个数据库从源复制到目标中的四个不同模式。但是第五个数据库的任务失败了，错误如下-
错误:所有复制槽都在使用
浏览 0提问于2018-10-19得票数 0
1回答
我的应用程序中的Kafka debezium-postgres连接器抛出了以下错误： at io.debezium.connector.postgresql.connection.PostgresConnection.getReplicationSlotState$Worker.run(ThreadPoolExecutor.java:628)
at
浏览 1提问于2020-01-07得票数 0
回答已采纳
我试图使用Debezium postgres连接器连接到。我在日志中得到了以下错误。(PostgresConnectorTask.java:127)
我突然意识到我需要向我的用户角色添加复制。当您为PostgreSQL实例创建一个新的Cloud时，默认的postgres用户已经为您创建了，尽管您必须设置其密码。postgres用户是cloudsqlsuperuser角色的一部分，具有以下属性(特权)：CREATEROLE、CREATEDB和LOGIN。
浏览 2提问于2019-10-19得票数 5
我正面临以下情况：
我必须将我的Cloud SQL PostgreSQL实例逻辑复制到外部PostgreSQL数据库，反之亦然。更具体地说，CloudSQL和外部实例将包含一些必须在每个数据库之间复制的主表和从表。但是，GCP目前不支持PostgreSQL逻辑和外部复制。因为它不受支持，所以我一直在寻找替代方案，我注意到Debezium + Kafka可以与CloudSQL MySQL一起使用，以捕获数据库更改并执行逻辑复制。我在Debezium google组(链接如
浏览 3提问于2018-06-21得票数 6
我有一个问题，试图运行kafka connect与postgres debezium连接器，而使用docker，它找不到一个特定的类，位于一个debezium-core的jar。我已经下载了debezium postgres插件，并将其内容复制到我定义的plugin.path路径(/kafka/plugins)中。即使kafka connect首先加载debezium内核和api，错误仍然会出现。org.apache.kafka.c
浏览 3提问于2020-08-13得票数 0
需要帮助，我只是尝试创建postgres-debezium-pub/sub/bigquery。) Creating thread debezium-postgresconnector-debezium-postgres-keep-alive
2022-03-25 08:44:13,177 INFO\[io.deb.con.pos.PostgresSchema\] (debezium-postgresconnector-debezium</e
浏览 26提问于2022-03-25得票数 0
1回答
我在容器中有Debezium，捕获PostgeSQL数据库记录的所有更改。但我无法理解关于Debezium如何工作的几件事。如果Debezium第一次启动，它将获取数据库的快照，然后根据Debezium文档启动基于WAL文件的流。连接器完成快照后，它将继续从快照创建的确切位置进行流更改。这样，连接器从所有数据的一致视图开始，并且不会忽略快照拍摄时所做的任何更改。该连接器具有容错能力。当数据库的快照完成，然后从WAL文件中流出来时，如果连接器关闭，直到上升，WAL被清除/刷新，那么Debe
浏览 15提问于2022-11-01得票数 0
回答已采纳
我正在使用Debezium (一个Kafka连接器)来捕获Postgres数据库的更改，并且从Debezium获得了一个错误。是否有人知道下面的错误意味着什么，并可能提出解决它的建议。我试过debezium/connect:1.4，它能工作.但没有使用debezium/connect:1.5+ (1.9的版本与现有版本一样高，并且不工作(与下面的错误相同)
Postgres|dbserver1[io.debezium</em
浏览 24提问于2022-05-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
