阿里云文档 2026-06-03

创建oss sink connector

本文介绍如何创建使用OSS Sink Connector,您可以通过OSS Sink Connector将数据从云消息队列 Kafka 版的数据源Topic导出至对象存储OSS的Object中。

阿里云文档 2026-05-25

在Confluent中管理Connector插件

本文向您介绍不同版本云消息队列 Confluent 版所支持的Connector种类,以及如何添加和卸载Connector组件。

阿里云文档 2026-04-28

创建FC Sink Connector

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为函数计算的消息流出任务。

阿里云文档 2026-04-23

创建Kafka Sink Connector

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

阿里云文档 2026-04-23

创建SMQ Sink Connector

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

文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之如何使用Kafka Connector将数据写入到Kafka

问题一:Flink CDC里之前用mysql数据库join比较慢,这种join性能会比较好吗? Flink CDC里之前用mysql数据库join比较慢,所以才改成同步宽表到es,不知道doris,starorcks 这种join性能会比较好吗? 参考答案: Flink CDC 主要用于捕获和处理数据库变更数据流,而不是直接优化JOIN操作。MySQL...

实时计算 Flink版产品使用问题之如何使用Kafka Connector将数据写入到Kafka
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之使用kafka connector时,报错:java.lang.ClassNotFoundException,是什么原因

问题一:Flink使用 kafka connector 报错 Caused by:有人知道为什么吗? Flink使用 kafka connector 报错 Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource 有人知道为什么吗? ...

实时计算 Flink版操作报错合集之使用kafka connector时,报错:java.lang.ClassNotFoundException,是什么原因

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

产品推荐

消息队列

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

+关注