debezium 1.2 для разъема postgres 10

У меня есть версия 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


person Vijaya Rani    schedule 18.12.2020    source источник
comment
Вы установили плагин wal2json?   -  person Iskuskov Alexander    schedule 18.12.2020
comment
да. клонированный github.com/eulerto/wal2json. 2) скомпилировал wal2json, отредактировав файл wal2json.vcxproj, и изменил c: \ postgres \ pg103 на каталог префиксов PostgreSQL. 3) открыл этот файл проекта в MS Visual Studio и скомпилировал его. скопировал wal2json.dll в каталог pg_config --pkglibdir.   -  person Vijaya Rani    schedule 20.12.2020
comment
Также добавлены следующие строки в pg_hba.conf host all all all md5 host replication postgres 0.0.0.0/0 trust и run alter table product replica identity full   -  person Vijaya Rani    schedule 20.12.2020
comment
Также проверьте этот ответ stackoverflow.com/a/62787477/7109598   -  person Iskuskov Alexander    schedule 20.12.2020