Flink CDC这个该调什么参数?

Flink CDC这个该调什么参数?image.png

展开
收起
真的很搞笑 2023-09-13 15:11:01 206 分享 版权
1 条回答
写回答
取消 提交回答
  • Flink CDC 有许多参数可以调节,具体需要调哪些参数,取决于你的实际需求。

    以下是一些比较常用的参数:

    scan.parallelism: 这个参数用于控制 Flink CDC 的并行度,默认值是 1。如果数据量大,可以适当提高这个参数。
    buffer.size: 这个参数用于控制 Flink CDC 的缓冲区大小,默认值是 100MB。如果数据量大,可以适当提高这个参数。
    max.poll.records: 这个参数用于控制 Flink CDC 每次从 Kafka 中拉取多少条数据,默认值是 10000。如果数据量大,可以适当提高这个参数。
    commit.interval.ms: 这个参数用于控制 Flink CDC 每隔多长时间向 Kafka 中提交一次偏移量,默认值是 5000 毫秒。如果数据量大,可以适当延长这个参数。
    建议你根据实际情况,尝试调整这些参数,以找到最适合你的数据量的参数配置。

    2023-10-20 15:26:03
    赞同 展开评论

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

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