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...