是查询的时候报错,建表是成功的。 select * from postgres_cdc_test 错误: [ERROR] Could not execute SQL statement. Reason: org.postgresql.util.PSQLException: ERROR: syntax error
在 2022-12-02 10:09:37,"bmw" <panmin...@163.com> 写道: HI flink postgresql CDC flink1.12 ,postgresql:9.6.21 报错: CREATE TABLE postgres_cdc_test ( id INT, name STRING, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector' = 'postgres-cdc', 'hostname' = '192.168.1.101', 'port' = '5432', 'username' = 'postgres', 'password' = 'test', 'database-name' = 'test', 'schema-name' = 'public', 'table-name' = 'test', 'debezium.slot.name' = 'customslotname', 'decoding.plugin.name' = 'pgoutput' ); 错误信息: