云消息队列 Kafka 版的Connector共有两个版本,本文介绍新旧两版的创建方式及具体差异点。

创建方式

若您的阿里云账号未创建过旧版Connector,那么控制台仅展示新版入口;若已创建过旧版Connector任务,控制台会同时展示新版和旧版入口,建议您使用新版Connector。

新版Connector创建方式

登录云消息队列 Kafka 版控制台,在左侧导航栏单击Connector生态集成,可根据需求选择创建消息流入(Source)消息流出(Sink)任务。

旧版Connector创建方式

登录云消息队列 Kafka 版控制台,在左侧导航栏单击Connector任务列表中,可根据需求选择创建流入Connector或流出Connector任务。

说明 如果您的阿里云账号未创建过旧版Connector任务,则看不到此入口,可按需选择新版Connector创建方式。

能力差异

新旧版本Source Connector能力相同,此处对Sink Connector能力差异做以下说明。

差异项新版Sink Connector(推荐)旧版Sink Connector
底层依赖能力底层依赖事件总线EventBridge函数计算FC(Function Compute)构建。
说明 SLS Sink Connector仅依赖事件总线EventBridge
底层能力未统一,主要包含三大类:
  • 依赖事件总线EventBridge
  • 依赖函数计算FC(Function Compute)
  • 不依赖任务云服务。

创建的Connector具体属于哪一类需查看对应的Connector文档。

消息过滤支持多种消息过滤模式,过滤无用消息,提升处理效率。详细信息,请参见事件模式不支持。
死信队列支持消息服务MNS云消息队列 RocketMQ 版等服务做死信队列。支持云消息队列 Kafka 版做死信队列。
重试策略统一支持。部分支持。
依赖Kafka资源不额外依赖。系统自动或手动创建任务位点Topic、任务配置Topic、任务状态Topic、死信队列Topic、异常数据Topic等资源。
跨账号传输暂不支持。如有需求提交工单申请。支持。
消费线程并发数可自定义配置32以内的消费线程并发数。仅支持配置以下选项:1、2、3、6、12。
消费组可新建或复用已有资源。仅支持新建消费组。