Flink CDC 时初始化MySQL或者PG同步账号
1.MySQL CDC 账号,小写字符是需要动态调整的,修改密码后需要用新密码重新授权
1.1 创建账号
CREATE USER 'cdc'@'localhost' IDENTIFIED BY 'password';
1.2 授权
GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'cdc' IDENTIFIED BY 'password';
1.3 刷新
FLUSH PRIVILEGES;
2.PG CDC 账号,小写字符是需要动态调整的
2.1 创建账号
CREATE USER cdc WITH PASSWORD 'password';
2.2 授权
ALTER ROLE cdc REPLICATION;
2.3 授权cdc账号能连接的库
GRANT CONNECT ON DATABASE test TO cdc;
2.4 命令在库内部进行操作
2.4.1 把当前库public下所有表查询权限赋给用户
GRANT SELECT ON ALL TABLES IN SCHEMA public TO cdc;
GRANT REFERENCES on ALL TABLES IN SCHEMA public to cdc;
2.4.2 如果已经所有表进行发布,那就不用看这个问题, 此处PUBLICATION名字必须为dbz_publication
CREATE PUBLICATION DBZ_PUBLICATION FOR ALL TABLES;
2.5 验证,执行查询SQL查看是否存在发布的表
SELECT * FROM PG_PUBLICATION_TABLES;
3.PG其他辅助命令