阿里云文档 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)。

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

kafka table connector保留多久的数据

你好, 用kafka table connector接过来的数据,在flink这边会保留多久,在参数列表里没有看到有这个设置,如果保留太久,内存会撑暴,比如我只想保留半个小时,之前的数据可以清除。*来自志愿者整理的flink邮件归档

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

kafka table connector eventTime的问题

你好。 在用kafka table connector时如果使用eventTime,需要怎么启用这个eventTime, 没有找到一些相应的sample, 我是这样用的, 1. 设置Stream环境setStreamTimeCharacteristic(TimeCharacteristic.EventTime); 2. 在connector里指定watermark,其中transTime是消息.....

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

产品推荐

消息队列

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

+关注