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，也会一个算子固定消费一个分区吗？
flink sql没法指定并行度。那kafka数据消费不过来，怎么办 #Flink
flink sql没法指定并行度。那kafka数据消费不过来，怎么办 #Flink
请问Flink的最大并行度跟kafka partition数量有关系吗? source的并行度应该最
请问Flink的最大并行度跟kafka partition数量有关系吗? source的并行度应该最好是跟partition数量一致吧，那剩下的算子并行度呢？ 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
社区圈子
云消息队列 Kafka 版您可能感兴趣
- 云消息队列 Kafka 版频繁
- 云消息队列 Kafka 版消费者
- 云消息队列 Kafka 版rebalance
- 云消息队列 Kafka 版堆积
- 云消息队列 Kafka 版数据
- 云消息队列 Kafka 版设置
- 云消息队列 Kafka 版flink
- 云消息队列 Kafka 版apache
- 云消息队列 Kafka 版学习笔记
- 云消息队列 Kafka 版安装
- 云消息队列 Kafka 版消费
- 云消息队列 Kafka 版cdc
- 云消息队列 Kafka 版分区
- 云消息队列 Kafka 版mysql
- 云消息队列 Kafka 版集群
- 云消息队列 Kafka 版消息
- 云消息队列 Kafka 版同步
- 云消息队列 Kafka 版消息队列
- 云消息队列 Kafka 版topic
- 云消息队列 Kafka 版配置
- 云消息队列 Kafka 版sql
- 云消息队列 Kafka 版报错
- 云消息队列 Kafka 版实战
- 云消息队列 Kafka 版spark
- 云消息队列 Kafka 版类型