阿里云文档 2024-12-04

创建SMQ Sink Connector

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

阿里云文档 2024-12-04

创建Kafka Sink Connector

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

阿里云文档 2024-12-04

创建oss sink connector

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

阿里云文档 2024-12-04

创建FC Sink Connector

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

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

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

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

问答 2024-02-25 来自:开发者社区

Flink CDC里官网这个实例中的kafkasink是在哪里实现的呢?

在使用 Flink CDC 进行数据流处理时,我注意到在Flink的源码中似乎没有看到对应 Kafka 的 sink 连接器实现。然而,官方示例中提到了 Kafka sink,我想请问这个 Kafka sink 是在哪里实现的?此外,在尝试编译并运行相关的 pull request 时,无法控制发送 schema change,且发送的Log里字段名称变成了f1,f2序列,没有按预期展示字段名称....

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

Flink CDC里sink到kafka出现的报错怎么办?

Flink CDC里sink到kafka出现的报错怎么办?启动的时候应该是创建了topic

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

Flink CDC支持这种写法吗?将kafka的数据sink到postgresql和kafka行吗?

INSERT INTO my_postgres_sink, my_kafka_sink SELECT * FROM kafka_table;Flink CDC里支持这种写法吗?将kafka的数据sink到postgresql和kafka可以不?

文章 2024-01-18 来自:开发者社区

阿里云Flink-自定义kafka sink partitioner实践及相关踩坑记录

1. 背景及需求链路:Flink -> sink kafka需求:客户需求根据数据的特征,以自定义的逻辑,将不同的数据写到kafka不同的分区中阿里云官方文档链接:https://help.aliyun.com/zh/flink/developer-reference/kafka-connector?spm=a2c4g.11186623.0.0.bc541be5ucyowS#section....

阿里云Flink-自定义kafka sink partitioner实践及相关踩坑记录
问答 2023-11-30 来自:开发者社区

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

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

产品推荐

云消息队列

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

+关注