Кафка коннект Debezium Postgres Cloud SQL

Question

Я пытаюсь подключиться к Cloud SQL postgres с помощью коннектора Debezium 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 говорят следующее:

Когда вы создаете новый экземпляр Cloud SQL для PostgreSQL, пользователь postgres по умолчанию уже создан для вас, хотя вы должны установить его пароль. Пользователь postgres является частью роли cloudsqlsuperuser и имеет следующие атрибуты (привилегии): CREATEROLE, CREATEDB и LOGIN. У него нет атрибутов SUPERUSER или REPLICATION.

Теперь из-за этого я не могу ALTER ROLE добавить REPLICATION

ps: экземпляр SQL облака настроен на высокую доступность.

Answer 1

Для Debezium требуется расширение Postgres wal2json, которое в настоящее время не поддерживается Cloud SQL. Для этого существует текущий запрос функции , который можно проверить. Вам необходимо настроить Postgresql на GCE и настроить там Debezium.

Если это поможет, примите ответ