我的并行度设置的是和Kafka的分区保持一致的,一般建议改成分区的倍数吗-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

来自:阿里云实时计算Flink 2022-10-01 10:32:45 97 1

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

取消 提交回答
全部回答(1)
  • 游客tk3vic2jx2lk4
    2022-10-02 09:37:40

    不是叫你增加拉取kafka的并行度,是后面的并行度,kafka并行度增加了没用(此答案整理自Flink CDC 社区)

    0 0
相关问答

0

回答

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操

2022-08-24 16:58:49 170浏览量 回答数 0

0

回答

flink cdc 消费mongodb变更发到kafka用哪种格式合适?

2022-08-22 10:05:31 189浏览量 回答数 0

0

回答

有遇到flink读取kafka乱码的吗,如何解决?

2022-08-17 17:44:52 146浏览量 回答数 0

1

回答

flink消费kafka里cdc同步的数据,消费时怎么可以保证顺序

2022-08-15 10:48:11 146浏览量 回答数 1

1

回答

Flink kafka Producer的容错是什么?

2021-12-07 20:20:18 127浏览量 回答数 1

1

回答

Flink kafka Producer的Producer 分区是什么?

2021-12-07 20:19:12 240浏览量 回答数 1

1

回答

flink创建Kafka流表的方法是什么?

2021-12-07 20:26:01 198浏览量 回答数 1

1

回答

flink中Kafka流表关联HBase维度表的计算逻辑是什么呢?

2021-12-07 20:28:06 328浏览量 回答数 1

1

回答

Flink中Kafka源连接器的构造函数有哪些呢?

2021-12-07 21:57:51 120浏览量 回答数 1

1

回答

flink不清理state,从checkpoint恢复任务能重置kafka的offset讨论

2021-12-07 22:02:10 600浏览量 回答数 1
文章
问答
来源圈子
更多
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
+ 订阅
相关文档: 实时计算(流计算)
问答排行榜
最热
最新
相关电子书
更多
消息队列 Kafka 版差异化特性
立即下载
任庆盛|Flink CDC + Kafka 加速业务实时化
立即下载
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载