Flink mongoDB cdc这个语法结构 with参数这些不应该是吧？

这种哈，那个内部文档系统有点问题，几分钟后刷新就对了。CREATE TABLE tableName(
_id STRING,
name STRING,
price INT,
PRIMARY KEY(_id) NOT ENFORCED
) WITH (
'connector' = 'mongodb-cdc',
'hosts' = 'mongo.example.com:27017',
'username' = 'mongouser',
'password' = 'mongopasswd',
'database' = 'testdb',
'collection' = 'testcoll',
'scan.startup.mode' = 'initial'
); 此回答整理自钉群“实时计算Flink产品交流群”