阿里云文档 2025-09-09

如何将Kafka的数据迁移至MaxCompute

本文介绍如何使用DataWorks数据同步功能,将云消息队列 Kafka 版集群上的数据迁移至阿里云大数据计算服务MaxCompute,方便您对离线数据进行分析加工。

问答 2024-08-14 来自:开发者社区

flink sql作业中,计算结果可以动态写入kafka不同主题吗?

flink sql作业中,计算结果可以动态写入kafka不同主题吗?

问答 2023-09-17 来自:开发者社区

用flinkcdc读取rds的数据,然后再用flink计算指标,中间需要用kafka之类的中间件吗?

现在想用flinkcdc 读取rds的数据,然后再用flink计算指标,中间需要用kafka之类的中间件吗?

阿里云文档 2023-07-20

云消息队列 Kafka 版实例的Group规格如何计算

Group规格默认为分区规格的2倍。

阿里云文档 2023-05-24

如何计算Topic、Group和分区数

云消息队列 Kafka 版不再支持按照Topic规格购买实例。

问答 2023-05-23 来自:开发者社区

请问Flink CDC中计算结果需要同时写到kafka ,redis ,数据库表 只用一个自定义?

请问Flink CDC中计算结果需要同时写到kafka ,redis ,数据库表 只用一个自定义sink 写入到 3个地方;还是分别3个sink来实现?

文章 2022-02-17 来自:开发者社区

Blink流式计算-Kafka接入demo

//定义解析Kakfa message的UDTF CREATE FUNCTION myParse AS 'com.xxxxxx.MyKafkaUDTF'; CREATE FUNCTION myUdf AS 'com.xxxxxxx.MyWaterMarkUDTF'; //注意:kafka源表DDL字段必须与以下例子一致 create table my_input ( messageKey VAR....

问答 2022-02-15 来自:开发者社区

fink新增计算逻辑时kafka从头开始追平消费记录是怎么回事?

latest 不是最后消费的位置吗? 另外我一直不明白的是,如果我不新增新的算子,从savepoint启动是没有问题的。不会从头开始消费,之后新增算子后才会出现这个情况。*来自志愿者整理的FLINK邮件归档

问答 2022-02-15 来自:开发者社区

请问一下下游搞大屏的我们Flink将计算结果搞到 redis 好还是 kafka 好呀???

请问一下下游搞大屏的我们Flink将计算结果搞到 redis 好还是 kafka 好呀??? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注