阿里云文档 2025-02-17

创建RabbitMQ Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务,将云消息队列 RabbitMQ 版中的数据快速导入至云消息队列 Kafka 版。

阿里云文档 2025-02-17

创建SMQ Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流入任务,将轻量消息队列(原 MNS)中的数据快速导入云消息队列 Kafka 版。

阿里云文档 2025-02-17

创建Kafka Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务,将指定云消息队列 Kafka 版实例中的数据快速导入至另外的云消息队列 Kafka 版实例中。

阿里云文档 2025-02-17

创建MQTT Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务,将云消息队列 MQTT 版中的数据快速导入至云消息队列 Kafka 版实例中。

阿里云文档 2025-02-17

创建DTS Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流入源为数据传输服务DTS的消息流入任务。

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

mongo source cdc + kafka sink connector这个组合支持吗?

在Flink CDC中mongo source cdc + kafka sink connector这个组合支持Exactly Once语义吗?

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

flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

问答 2023-08-20 来自:开发者社区

大佬们,flink 如何动态更新source呀?如何自由增加和减少flink读取kafka的主题创建

大佬们,flink 如何动态更新source呀?如何自由增加和减少flink读取kafka的主题创建的source进行union呢?

问答 2023-08-20 来自:开发者社区

大佬们,Flink CDC 如何动态更新source呀? 如何自由增加和减少flink读取kafka

大佬们,Flink CDC 如何动态更新source呀? 如何自由增加和减少flink读取kafka的主题创建的source进行union呢?

问答 2023-08-01 来自:开发者社区

问个小白问题:Flink SQL里,source读取kafka数据,然后根据orderId 统计总?

问个小白问题:Flink SQL里,source读取kafka数据,然后根据orderId 统计总量;我使用 SELECT COUNT(orderId) FROM source_table;的方式来计算总数;我的疑问点是,flink是如何处理这些source数据的,比如 kafka推过来 100W条的数据,都在 flink的内存里吗?

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

产品推荐

云消息队列

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等