📌 📄 内容摘要:
dwlm 在 提交任务到Flink后可以正常运行，但是消费Kafka的Topic却发现没有数据 中发帖
%flink.ssql(injectCredentials=true)
DROP TEMPORARY TABLE IF EXISTS flink_cdc_users;
CREATE TEMPORARY TABLE flink_cdc_users (
user_id INT,
username VARCHAR,
email VARCHAR,
created_at TIMESTAMP,
PRIMARY KEY (user_id) NOT ENFORCED
) WITH (
‘connector’ = ‘postgres-cdc’,
‘hostname’ = ‘192.168.245.110’,
‘port’ = ‘5432’,
‘username’ = ‘hadoop’,
‘password’ = ‘hadoop’,
‘database-name’ = ‘postg...
────────── 链接信息 ──────────
🔗 论坛链接: linux.do
📎 访问地址: https://linux.do/t/topic/239972/1
─────────────────────────────
📢 来源：LINUX DO
