我们使用Debezium和Kafka-Connect从几个MariaDB数据库实例中获取数据。对于大多数数据库,连接器都能成功运行,但有一个数据库的连接器会失败,并显示以下错误:
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218)
at io.debezium.connector.mysql.SnapshotReade
目前,我正在Debezium Postgres连接器上进行负载测试,以了解它是否能够支持Aurora postgres中的大量更改日志(数十亿)。当我向postgres表插入100万条记录时,Debezium Postgres连接器出现以下错误消息失败:
org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped.
at io.debezium.connector.base.Chang
我有个Dockerfile
FROM strimzi/kafka:0.20.1-kafka-2.6.0
USER root:root
RUN mkdir -p /opt/kafka/plugins/debezium
# Download, unpack, and place the debezium-connector-postgres folder into the /opt/kafka/plugins/debezium directory
RUN curl -s https://repo1.maven.org/maven2/io/debezium/debezium-connector-p
我正在尝试使用Postgres和AWS动态设置debezium服务器,使用以下说明:
并在执行sh run.sh时面对这个问题
io.debezium.DebeziumException: Creation of replication slot failed
at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:143)
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTa
我正在尝试并设置一个复制用户。我创建复制用户的步骤如下:
CREATE ROLE replication_role WITH REPLICATION LOGIN;
CREATE USER debezium WITH PASSWORD 'my-secret-pw';
GRANT replication_role TO debezium;
CREATE ROLE replication_group WITH LOGIN;
GRANT replication_group TO postgres;
GRANT replication_group TO debezium;
A