Flink-cdc實時讀postgresql

由於公司業務需要，需要實時同步pgsql數據，我們選擇使用flink-cdc方式進行 架構圖： 前提步驟: 1，更改配置文件postgresql.conf # 更改wal日志方式為logicalwal_level = logical # minimal, replica ...

flink-cdc讀取postgres報異常，沒有發布表

異常信息 must be superuser to create FOR ALL TABLES publication 必須是超級用戶才能為所有發布表創建 網上搜索了一天，都毫無頭緒 ...