FLINK postgresql CDC 报语法错误

Thu, 01 Dec 2022 18:11:14 -0800 

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'
);


错误信息：

回复