flink cdc采集binlog到kafka极限是多少呀?多并行度,能提升采集性能吗?

flink cdc采集binlog到kafka极限是多少呀?多并行度,能提升采集性能吗,貌似原来的版本是单行度采集的吧?

kafka 分区小于 flink 并行度吗?

kafka 分区小于 flink 并行度吗?

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

Flink CDC这种只是争对kafka的,如果是针对flink的多并行度呢,是不是也是一致的呢?

Flink CDC这种只是争对kafka的,如果是针对flink的多并行度呢,是不是也是一致的呢!比方说我一个source并行度为4,那么是不是针对单条记录的增删改就会在一个并行度里呢,如果是这样的话,那么如果我加上schemaChange后,是不是其他几个并行线程的数据就会先于schemaChan...

kafka分区数4,flinksource并行度设置30 , 有些时候任务起不来是啥问题嘞?

kafka分区数4,flinksource并行度设置30 , 有些时候任务起不来是啥问题嘞?

请问kafka分区数和任务并行度这和一个分区被一个slot消费完全不符消费的数据量也差异是为什么?

请问kafka分区数和任务并行度一直,每个分区数据都是均匀的,但是source端显示有个slot并没有消费到数据,这和一个分区被一个slot消费完全不符,而且消费的数据量也是差异巨大是为什么?

我的并行度设置的是和Kafka的分区保持一致的,一般建议改成分区的倍数吗

我的并行度设置的是和Kafka的分区保持一致的,一般建议改成分区的倍数吗

1.13版的flinksql中kafka source支持单独设置并行度么

1.13版的flinksql中kafka source支持单独设置并行度么

问一个问题,cdc流模式同步数据到kafka,一开始并行度是2,运行一段时间后保存到保存点,重启时将

问一个问题,cdc流模式同步数据到kafka,一开始并行度是2,运行一段时间后保存到保存点,重启时将并行度改为1,这样会丢失数据吗?

请问一下,flink kafka source设置并行度,因为有多个topic需要订阅,应该怎么设置

请问一下,flink kafka source设置并行度,因为有多个topic需要订阅,应该怎么设置比较合理呢,是设置成topic数量,还是topic*分区数比较合理?

大佬们,接收kafka数据,假如kafka是3个分区,flink算子并行度我也设置为3,这样就会保证

大佬们,接收kafka数据,假如kafka是3个分区,flink算子并行度我也设置为3,这样就会保证一个算子固定的消费某一个分区了吧?假如有2个topic,一个有3个分区,一个有2个分区,flink我同时接收这2个topic,算子并行度设置为5,也会一个算子固定消费一个分区吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载

云消息队列 Kafka 版并行度相关内容