数据订阅功能支持创建消费组。通过创建多个消费组,您可以对同一个数据源的数据进行重复消费,从而降低数据订阅的使用成本。 注意事项 一个数据订阅实例最多可以创建20个消费组,通过创建多个消费组可以实现数据的重复消费。 一个消费组只能创建一个消费者(consumer),并通过该消费者执行数据消费。 若DTS用于读取增量数据的模块DStore或者客户端切换,则可能会导致数据重复。 操作步骤 进入新版DTS订阅任务的列表页面。 在页面左上角,选择订阅实例所属地域。 定位至目标的订阅实例,并单击实例ID。 单击左侧导航栏的数据消费。 在数据消费页面,单击左上角的新增消费组。 在弹出的数据消费对话框,设置消费组信息。 配置 说明 消费组名称 您可以根据需要修改消费组名称,建议配置具有业务意义的名称,便于后续识别。 账号 设置该消费组的账号信息。 由大写字母、小写字母、数字、下划线中的任意一种或多种组成。 最长16个字符。 密码 设置该消费组账号对应的密码信息。 由大写字母、小写字母、数字、特殊字符中的任意两种或两种以上组成。 密码长度为8~32个字符。 确认密码 再次填入相同的密码。 单击确定。 后续步骤 新增消费组后,根据消费客户端类型,选择订阅数据的消费方式: 使用SDK示例代码消费订阅数据(推荐) 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据