阿里云文档 2024-12-04

创建RabbitMQ Sink Connector

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

阿里云文档 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 版控制台创建流出目标为函数计算的消息流出任务。

问答 2022-09-23 来自:开发者社区

请问下 sink端到kafka的地址换了 还能从checkpoint重启吗

请问下 sink端到kafka的地址换了 还能从checkpoint重启吗

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

Flink sink kafka EXACTLY ONCE 执行checkpoint失败

#环境 Flink 版本: 1.10.1 kafka 版本:2.12-2.2.2 DAG:source kafka->etl->sink kafka 在at least once模式下运行正常,改为extractly once执行checkpoint每次都不成功。 #配置 尝试过增加以下配置: props.setProperty(ProducerConfig.TRANSACTION_T...

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

产品推荐

云消息队列

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

+关注