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

Flink mongoDB cdc这个语法结构 with参数这些不应该是吧?f89a3e5ab33af83fb106d27e833749f3.png

展开
收起
三分钟热度的鱼 2023-09-12 19:14:30 46 发布于安徽 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 这种哈,那个内部文档系统有点问题,几分钟后刷新就对了。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产品交流群”

    2023-09-12 20:07:45 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等