开发者社区大数据与机器学习实时计算 Flink 正文

大神们，数据在kafka的分区里是有序的，flink消费kafka分区，sink到es，怎么保持消息

大神们，数据在kafka的分区里是有序的，flink消费kafka分区，sink到es，怎么保持消息有序呢？

展开

收起

游客3oewgrzrf6o5c 2022-07-05 13:51:09 859 版权

1 条回答

写回答

取消提交回答

游客bcfx2q4kttgbm

（此答案整理自【③群】Apache Flink China社区）

2022-07-05 14:26:28

赞同展开评论

问答分类：

消息中间件 Kafka 流计算实时计算 Flink版云消息队列 Kafka 版

问答标签：

实时计算 Flink版数据实时计算 Flink版kafka 云消息队列 Kafka 版flink 云消息队列 Kafka 版数据实时计算 Flink版es

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？

1587

flink cdc3.0写入Doris mysql binlog如何保证有序？

337

flink cdc datastream方式同步mysql数据到kafka，多分区怎么保证有序性？

129

kafka可以一个topic得多个分区在同一个broker上吗？

222

kafka topic多个分区，同一个broker是什么情况？

dataworks读kafka写maxcompute按照这个update_time分区要怎么排查？

在Flink CDC中MySQL整库同步，Kafka Pipeline 不支持指定分区吗？

117

在Flink CDC中写入kafka，这个默认是根据什么分区的，表的主键吗？

116

消息队列Kafka版Topic分区数可以减少吗

124

Flink cdc模式同步mysql数据时怎么在全量阶段消费的数据有序

101

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

Apache Kafka 分布式流处理平台技术详解与实践指南

企业级实时消息推送系统的架构设计，一文即懂！

“企业微信iPad协议”凌晨断链：当最后一台测试机决定集体沉默

如何开发ERP（离散制造-MTO）系统中的生产管理板块（附架构图+流程图+代码参考）

五个让抓取流程更可控的小技巧

大神们，数据在kafka的分区里是有序的，flink消费kafka分区，sink到es，怎么保持消息

实时计算 Flink

相关文章

热门讨论

热门文章