当前位置：网站首页>大佬们，求助一下，我用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在收发数据，请教一下，这个是怎么回事儿呢？
采纳答案1：
读binlog阶段,只有一个并行度在读取（此答案整理自Flink CDC 社区）
边栏推荐
- Scala basic tutorial -- 18 -- set (2)
- Using SSH
- Caché JSON 使用JSON适配器
- 模板_判断素数_开方 / 六素数法
- Principle and application of ThreadLocal
- Scala基础教程--17--集合
- 字节跳动Dev Better技术沙龙成功举办，携手华泰分享Web研发效能提升经验
- Detailed explanation of the maturity classification of ITSS operation and maintenance capability | one article clarifies the ITSS certificate
- 2022 ByteDance daily practice experience (Tiktok)
- 正则替换【JS，正则表达式】
猜你喜欢
Scala basic tutorial -- 15 -- recursion
Scala basic tutorial -- 18 -- set (2)
Halcon模板匹配
vbs或vbe如何修改图标
Deleting nodes in binary search tree
Learning path PHP -- phpstudy "hosts file does not exist or is blocked from opening" when creating the project
How is the entered query SQL statement executed?
力扣刷题日记/day7/6.30
Scala基础教程--16--泛型
力扣刷题日记/day3/2022.6.25
随机推荐
千万不要只学 Oracle、MySQL！
爬虫（6） - 网页数据解析(2) | BeautifulSoup4在爬虫中的使用
Deleting nodes in binary search tree
Halcon template matching
Microservice architecture debate between radical technologists vs Project conservatives
完善的js事件委托
一种将Tree-LSTM的强化学习用于连接顺序选择的方法
Improve the accuracy of 3D reconstruction of complex scenes | segmentation of UAV Remote Sensing Images Based on paddleseg
Technology sharing | interface testing value and system
2022 ByteDance daily practice experience (Tiktok)
Is it safe to download the mobile version of Anxin securities and open an account online
6.26cf simulation race e: solution to the problem of price maximization
1、 Introduction to C language
Li Kou brush question diary /day4/6.26
基于lex和yacc的词法分析器+语法分析器
信息学奥赛一本通 1336：【例3-1】找树根和孩子
模板_大整数减法_无论大小关系
[211] go handles the detailed documents of Excel library
发送和接收IBM WebSphere MQ消息
How is the entered query SQL statement executed?