我有一个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的编码”
暂无答案!
目前还没有任何答案,快来回答吧!