У меня есть версия Postgres 10, и я пытаюсь настроить коннектор debezium с Kafka.
Ниже приведены настройки, которые я сделал
Set Wal_level = 'logical'
создал слот репликации:
SELECT * FROM pg_create_logical_replication_slot('slot_repl', 'test_decoding');
разъем debezium:
{
"name": "cid-staging-connector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"database.hostname": "localhost",
"database.port": "5433",
"database.user": "postgres",
"database.password": "xxxx",
"database.server.id": "54111",
"database.server.name": "postgres",
"database.dbname": "postgres",
"table.whitelist": "public.product",
"plugin.name": "wal2json",
"database.history.consumer.security.protocol":"SASL_SSL",
"database.history.producer.security.protocol":"SASL_SSL",
"database.history.consumer.sasl.mechanism":"SCRAM-SHA-512",
"database.history.producer.sasl.mechanism":"SCRAM-SHA-512",
"database.history.consumer.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"xxx\" password=\"xxx\";",
"database.history.producer.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"XXX\" password=\"xxx\";",
"database.history.kafka.bootstrap.servers": "xxx",
"database.history.kafka.topic": "schema-changes.cid_staging",
}
}
Но получаю ошибку ниже
error_code: 500, сообщение: не удалось получить кодировку для базы данных postgres