云消息队列 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。 | 底层能力未统一,主要包含三大类:
创建的Connector具体属于哪一类需查看对应的Connector文档。 |
消息过滤 | 支持多种消息过滤模式,过滤无用消息,提升处理效率。详细信息,请参见事件模式。 | 不支持。 |
死信队列 | 支持消息服务MNS和云消息队列 RocketMQ 版等服务做死信队列。 | 支持云消息队列 Kafka 版做死信队列。 |
重试策略 | 统一支持。 | 部分支持。 |
依赖Kafka资源 | 不额外依赖。 | 系统自动或手动创建任务位点Topic、任务配置Topic、任务状态Topic、死信队列Topic、异常数据Topic等资源。 |
跨账号传输 | 暂不支持。如有需求请提交工单申请。 | 支持。 |
消费线程并发数 | 可自定义配置32以内的消费线程并发数。 | 仅支持配置以下选项:1、2、3、6、12。 |
消费组 | 可新建或复用已有资源。 | 仅支持新建消费组。 |