我正在尝试使用Debezium Postgres连接器连接到Cloud SQL postgres。
而且我在日志中收到以下错误。
connect_1 | org.apache.kafka.connect.errors.ConnectException: org.postgresql.util.PSQLException: FATAL: must be superuser or replication role to start walsender
connect_1 | at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:127)
我想到我需要将REPLICATION添加到我的用户角色中。
但是，CloudSQL文档说以下内容。
当您为PostgreSQL实例创建新的Cloud SQL时，尽管必须设置密码，但已经为您创建了默认的postgres用户。
postgres用户是cloudsqlsuperuser角色的一部分，并且具有以下属性(特权):CREATEROLE，CREATEDB和LOGIN。它没有SUPERUSER或REPLICATION属性。
现在正因为如此，我无法更改角色以添加REPLICATION
ps:将云SQL实例配置为具有高可用性。
最佳答案
Debezium需要Postgres wal2json扩展名，Cloud SQL当前不支持该扩展名。您将需要feature request并在那里设置Debezium。
如果有帮助，请接受答案