请问flink cdc 中Datastream api 可以设置每秒同步的条数的吗？
问题1：请问flink cdc 中Datastream api 可以设置每秒同步的条数的吗？
问题2：那我怎么更好控制宽带的占用呢？因为初始化数据量比较大，然后不控制好条数，宽带直接占满了。
写回答
-
北京阿里云ACE会长是的，Flink CDC 中的 DataStream API 可以通过设置 setMaxParallelism() 方法和 setParallelism() 方法来控制每秒同步的条数。
setMaxParallelism() 方法用于设置流的最大并行度，即可以并行运行的最大任务数。在 Flink CDC 中，最大并行度通常与 Kafka 的分区数相同，因为每个 Kafka 分区都会被分配到一个 Flink Task Slot 中。如果您希望每秒同步的条数更多，可以增加流的最大并行度，以增加任务并行度。
setParallelism() 方法用于设置流的并行度，即任务的并行度。在 Flink CDC 中，每个任务都会从 Oracle 数据库中读取数据，并将数据写入 Kafka Topic 中。如果您希望每秒同步的条数更多，可以增加任务的并行度，以增加数据读取和写入的并行度。
2023-07-29 21:07:49赞同 展开评论 打赏 -
意中人就是我呀！"回答1：不可以。
回答2：配合2.4版本，增量阶段会释放无用资源链接，全量数据加大并行度，到增量阶段只有1个并行度或者手动savepoint启动，我们用的是阿里的自动调优。
看看这两个参数。
这事情得晚上再试试。此回答整理至钉群“Flink CDC 社区”。"2023-07-19 17:24:29赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
