阿里云文档 2025-03-24

如何快速构建一个从Kafka到Hologres的数据同步作业

实时计算Flink版提供丰富强大的日志数据实时入仓能力。本文为您介绍如何在实时计算管理控制台上快速构建一个从Kafka到Hologres的数据同步作业。

阿里云文档 2024-12-02

通过SparkStreaming作业处理Kafka数据

本文介绍在阿里云E-MapReduce创建的包含kafka服务的DataFlow集群中,如何使用Spark Streaming作业从Kafka中实时消费数据。

问答 2024-07-03 来自:开发者社区

Flink的作业为啥kafka的消息没有sink到ADB?

Flink的作业为啥kafka的消息没有sink到ADB?

问答 2024-05-29 来自:开发者社区

Flink消费Kafka source显示作业延迟为52年

Flink消费Kafka source显示作业延迟为52年

问答 2024-04-06 来自:开发者社区

Flink 数据源是kafka , 一条流数据是设备的作业指令进度数据(多次更新),如何解决?

Flink 数据源是kafka , 一条流数据是设备的作业指令进度数据(多次更新),一条流是设备的状态(多次更新),有没有比较好的方法将两个流进行关联(以设备号关联),获取实时的指令进度信息和对应设备最新状态?

问答 2024-03-27 来自:开发者社区

我的 kafka数据到目标表的作业 ,要进行 无状态 启动时。Flink是不是就没办法 全量同步

我如果 先用 CDAS 同步 mysql 数据到 kafka,那kafka 数据是会消费的,这样的话,我的 kafka数据到目标表的作业 ,要进行 无状态 启动时。Flink是不是就没办法 全量同步 了?

问答 2024-03-26 来自:开发者社区

flink作业数据来源是kafka ,配置偏移量策略是earlest,有什么办法吗?

flink作业数据来源是kafka ,配置偏移量策略是earlest,而且作业使用了rockdb状态后端,状态的生命周期是1个月, 目前kafka中的数据只能存3天,但是作业需要停7天 ,想重启作业时尽可能的多消费数据 且 停止作业时的保存点中的状态不丢数 ,有什么办法吗? 是直接就保存保存点 然后停止作业,7天后直接从保存点启动作业吗?

问答 2024-01-17 来自:开发者社区

Flink中sql作业发送json格式到kafka,可以指定json里的key值吗?

Flink中sql作业发送json格式到kafka,可以指定json里的key值吗?

问答 2023-10-11 来自:开发者社区

请教大佬们,有没有遇到过一个问题,场景:消费KAFKA写ES过程中,作业假死。现象:作业没有报错,但

请教大佬们,有没有遇到过一个问题,场景:消费KAFKA写ES过程中,作业假死。现象:作业没有报错,但是不消费KAFKA了,也不写ES了,数据不流动了 kafka大概60-180个分区不等 我是一套代码 跑了10个程序 消费了不同的TOPIC

问答 2023-07-26 来自:开发者社区

Flink CDC中我一个流作业kafka接收到的一个表数据想跟一个固定数据集做关联 该怎么做?

Flink CDC中我一个流作业里面 我从kafka接收到的一个表数据 想跟一个固定数据集做关联 该怎么做呢 ?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注