flinksql postgres cdc

根据提供的引用内容，flinksql postgres cdc的实现需要遵循以下步骤：

1. 确保使用的是'postgres-cdc'连接器。在Flink SQL中，可以使用以下语句创建一个PostgreSQL CDC源表：

   CREATE TABLE source_table (
     ...
   ) WITH (
     'connector' = 'postgres-cdc',
     'hostname' = 'localhost',
     'port' = '5432',
     'username' = 'postgres',
     'password' = 'postgres',
     'database-name' = 'mydatabase',
     'schema-name' = 'public',
     'table-name' = 'mytable'
   )

其中，'hostname'，'port'，'username'和'password'应该替换为正确的PostgreSQL连接信息，'database-name'，'schema-name'和'table-name'应该替换为正确的表信息。

2. 确保PostgreSQL服务器已启用CDC。可以通过以下步骤重新加载配置或重启PostgreSQL来启用CDC：

   # 重新加载配置
   docker exec -it <container_id> /bin/bash
   su postgres
   pg_ctl reload

   # 或者重启PostgreSQL
   docker restart <container_id>

其中，'<container_id>'应该替换为正确的PostgreSQL容器ID。

3. 在Flink SQL中使用SELECT语句查询源表并将结果写入目标表。例如：

   INSERT INTO target_table
   SELECT ...
   FROM source_table

其中，'target_table'应该替换为正确的目标表名称，'source_table'应该替换为正确的源表名称，'SELECT ...'应该替换为正确的查询语句。