当前位置：网站首页>大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置

大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置

2022-07-04 17:36:00 【阿里云问答】

大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置8个并行度，生产环境跑着8个subtask，但只有一个subtask在收发数据，请教一下，这个是怎么回事儿呢？896问.png



采纳答案1：

读binlog阶段,只有一个并行度在读取（此答案整理自Flink CDC 社区）

原网站

版权声明
本文为[阿里云问答]所创，转载请带上原文链接，感谢
https://developer.aliyun.com/ask/438141

边栏推荐

猜你喜欢

随机推荐