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

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

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

展开

收起

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

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 cdc datastream方式同步mysql数据到kafka，多分区怎么保证有序性？

122

大数据计算MaxCompute在odps上有一个kafka同步到es的离线任务任务是这么配置的？

DataWorks在odps上有一个kafka同步到es的离线任务任务是这么配置的？

DataWorks中odps+flink数据同步，odps在数据地图上已经能看到分区了？

104

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

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

在Flink CDC中如下是这个参数控制保留hive 多久的分区吗？

在Flink CDC中这种配置，会自动删除超过30天前的hive分区吗？

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

114

Flink这个normal 模式，怎么没有办法设置分区？

大数据与机器学习

实时计算 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，提供丰富的企业级增值功能。

可视化生成RocketMQ配置工具

数据当“安全带”：金融市场如何用大数据玩转风险控制？

从纳秒到毫秒的“时空之旅”：CPU是如何看待内存与硬盘的？

使用Koopman理论识别机器人动力学的非线性系统（Matlab代码实现）

分布式爬虫的全局请求间隔协调与IP轮换策略

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

实时计算 Flink

相关文章

热门讨论

热门文章