文档中心

数据库传输服务

请输入

消费订阅数据

新建消费组

成功创建数据订阅任务之后，需要根据消费端的类型在 DTS 控制台或通过开源 Kafka SDK 创建消费组。本文介绍如何通过数据库传输服务 DTS 控制台为内置中间件新建消费组。

背景信息

消费组是一组具有相同消费组 ID 的消费者。当一个 Topic 被同一个消费组的多个消费者消费时，每一条消息都只会被投递到一个消费者，实现消费的负载均衡。通过消费组，您可以确保一个 Topic 的消息被并行消费。

创建数据订阅任务之后，数据库的数据更新和结构更新均以消息数据的形式投递到指定的消费端，您还需要创建对应的消费组以消费数据。不同类型的消费端创建消费组的方式如下：

消息队列 Kafka 版：使用消息队列 Kafka 版的 SDK 创建消费组（Group），创建后可以在消息队列 Kafka 版控制台中查看 Group 列表。详细信息请参见消息队列 Kafka 版 SDK 参考。

消息队列 RocketMQ 版：使用消息队列 RocketMQ 版创建消费组（Group），创建后可以在消息队列 RocketMQ 版控制台中查看 Group 列表。详细信息，请参考创建 Group。

使用限制

前提条件

操作步骤

参数	描述
消费组名称	自定义消费组名称。建议设置和您的业务有相关联的名称，便于后续查询。名称命名规则如下：长度需在 2~32 个字符内。由数字、大写字母、小写字母、下划线（_）和中划线（-）组成。
账号	设置消费组账号。账号命名规则如下：长度需在 2~16 个字符内。以字母开头，字母或数字结尾。由数字、大写字母、小写字母、下划线（_）组成。
密码	设置消费组账号密码。密码规则如下：长度需在 8~32 个字符内。至少包含大写字母、小写字母、数字或特殊字符中的三种类型。特殊字符包含 _#!@$%^&*()+=-。
确认密码	再次输入消费组账号密码。

API	描述
CreateSubscriptionGroup	调用 CreateSubscriptionGroup 接口创建订阅消费组。
DescribeSubscriptionGroup	调用 DescribeSubscriptionGroup 接口查询订阅消息组。
DescribeSubscriptionGroups	调用 DescribeSubscriptionGroups 接口查询消费组列表。
DescribeSubscriptionGroupProgress	调用 DescribeSubscriptionGroupProgress 接口查询订阅消费组进度。