用于postgres 10连接器的debezium 1.2

wfypjpf4  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(465)

我有一个postgres10版本,并试图建立与Kafkadebezium连接器。
下面是我做的设置

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",
    }
}

但是得到下面的错误
错误代码:500,“消息”:“无法获取数据库postgres的编码”

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题