备案控制台
探索云世界
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink中sink多个并行度写入rabbit mq会导致顺序性问题吗？

Flink中sink多个并行度写入rabbit mq会导致顺序性问题吗？

展开
收起
cuicuicuic 2024-04-23 12:45:05 17 0
1 条回答
写回答
取消 提交回答
  • xin在这

    会的，Sink会根据异常或者性能影响快慢 ，此回答整理自钉群“【③群】Apache Flink China社区”

    2024-04-23 17:08:52
    赞同 展开评论 打赏
问答分类：
流计算 消息中间件 实时计算 Flink版 云消息队列 MQ
问答标签：
实时计算 Flink版sink并行度 实时计算 Flink版并行度 实时计算 Flink版sink mq 实时计算 Flink版mq flink云消息队列 MQ
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答
实时计算 Flink版
Flink CDC里我这边6个并行度抽全量，source倾斜了怎么办？
20
1
0
Flink CDC里sink多个并行度写入mq会导致顺序性问题吗？
15
1
0
请问下，官方有提供flink Sink websocket的connector吗？
16
0
0
各位大佬，请教一下，如果在flink cdc sql客户端 使用SQL查询表，怎么能记录原系统的数据
1851
1
0
那cdc最新版支持到flink的哪个版本，flink1.15还有guava兼容性问题吗？
965
0
0
flink cdc(mysql) -> elasticsearch7, 任务每次持续跑了一段时间之后
930
2
0
各位大佬，请教个问题，使用flink cdc读取数据时，如果配置一个表，数据过滤是发生在server
1709
3
0
flink cdc 怎么做断点续传啊
5690
6
0
我使用flink cdc StartupOptions.latest() 采最新的日志。要是程序挂了
1216
5
0
请教下有flink cdc 对接mysql5.6的demo么？我这边显示各种包错误
1022
4
0
大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

热门讨论

热门文章

  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    1637
  • flink1.15启动后无法访问webui的问题有人遇到过吗
    9686
  • Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行
    641
  • Caused by: org.apache.kafka.common.errors.TimeoutE
    2150
  • Flink CDC有遇见这个问题的吗？
    371
  • Flink CDC中The MySQL server has a 兄弟们这个错误咋搞啊？
    404
  • Flink 语句有啥方法不写字段能直接拥有源表的所有字段？
    714
  • flink都是100%占用，请问是什么情况呢？
    404
  • Alink是什么意思？
    1856
  • flink任务报错: Job leader for job id 是啥原因导致的呢?
    815
    • 展开全部
  • 通过Flink实时构建搜索引擎的索引
    16787
  • 年度回顾 | 2019 年的 Apache Flink（文末有福利）
    4197
  • Apache Flink 零基础入门（一）：基础概念解析
    9735
  • Flink Kafka Connector 与 Exactly Once 剖析
    4911
  • Apache Flink 零基础入门（七）：Table API 编程
    2598
  • Flink 完美搭档：数据存储层上的 Pravega
    2277
  • 阿里云实时计算Flink的产品化思考与实践【下】
    110992
  • Flink DataStream API 批处理能力演进之路
    148
  • Flink CDC 3.0 正式发布，详细解读新一代实时数据集成框架
    100451
  • 阿里巴巴瓴羊基于 Flink 实时计算的优化和实践
    245
    • 展开全部

    相关课程

    更多
  • 消息队列 RocketMQ 消息集成
    331
    8
    去学习
  • 消息队列 MNS 入门课程
    2268
    9
    去学习
  • RocketMQ知识精讲与项目实战（第一阶段）
    711
    34
    去学习
  • RocketMQ知识精讲与项目实战（第二阶段）
    270
    54
    去学习
  • RocketMQ知识精讲与项目实战（第三阶段）
    308
    60
    去学习
  • 微服务实战-RocketMQ Binder
    1965
    6
    去学习

    • 相关文章

  • 大数据组件之Storm简介
  • 构建高效微服务架构：后端开发的新范式
  • 11缓存·
  • java基于云部署的SaaS医院云HIS系统源码 心理CT、B超 lis、电子病历
  • 22缓存

    • 相关电子书

    更多
    • RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载

    相关实验场景

    更多
  • RocketMQ监控/告警一站式搭建应用
    1113
    1.0小时
    去实验
  • RocketMQ运维自我实践
    570
    0.5小时
    去实验
  • RocketMQ的常规运维实践应用
    786
    1.0小时
    去实验
  • RocketMQ中使用Java客户端发送消息和消费的应用
    928
    1.0小时
    去实验
  • RocketMQ一站式入门使用
    4341
    1.0小时
    去实验