- 动态与公告
- 产品简介
- 购买指南
- 快速入门
- 准备工作
- 数据迁移
- 数据同步
- 数据订阅（Kafka 版）
- 前置校验不通过处理方法
- 割接说明
- 监控与告警
- 运维管理
- 实践教程
- 常见问题
- 错误处理
- API 文档
- History
- Introduction
- API Category
- Making API Requests
- (NewDTS) Data Migration APIs
- DescribeMigrationJobs
- ModifyMigrationJob
- CompleteMigrateJob
- DescribeMigrationDetail
- CreateMigrationService
- CreateMigrateCheckJob
- DescribeMigrationCheckJob
- SkipCheckItem
- StartMigrateJob
- StopMigrateJob
- ResumeMigrateJob
- RecoverMigrateJob
- ModifyMigrateName
- ModifyMigrateJobSpec
- IsolateMigrateJob
- DestroyMigrateJob
- DescribeMigrateDBInstances
- PauseMigrateJob
- ContinueMigrateJob
- Data Sync APIs
- DescribeSyncJobs
- ModifySyncJobConfig
- CreateModifyCheckSyncJob
- DescribeModifyCheckSyncJobResult
- StartModifySyncJob
- CreateSyncJob
- ConfigureSyncJob
- CreateCheckSyncJob
- SkipSyncCheckItem
- DescribeCheckSyncJobResult
- StartSyncJob
- StopSyncJob
- ResumeSyncJob
- ResizeSyncJob
- RecoverSyncJob
- IsolateSyncJob
- DestroySyncJob
- PauseSyncJob
- ContinueSyncJob
- Data Consistency Check APIs
- Data Types
- Error Codes
- DTS API 2018-03-30
- 相关协议
- 动态与公告
- 产品简介
- 购买指南
- 快速入门
- 准备工作
- 数据迁移
- 数据同步
- 数据订阅（Kafka 版）
- 前置校验不通过处理方法
- 割接说明
- 监控与告警
- 运维管理
- 实践教程
- 常见问题
- 错误处理
- API 文档
- History
- Introduction
- API Category
- Making API Requests
- (NewDTS) Data Migration APIs
- DescribeMigrationJobs
- ModifyMigrationJob
- CompleteMigrateJob
- DescribeMigrationDetail
- CreateMigrationService
- CreateMigrateCheckJob
- DescribeMigrationCheckJob
- SkipCheckItem
- StartMigrateJob
- StopMigrateJob
- ResumeMigrateJob
- RecoverMigrateJob
- ModifyMigrateName
- ModifyMigrateJobSpec
- IsolateMigrateJob
- DestroyMigrateJob
- DescribeMigrateDBInstances
- PauseMigrateJob
- ContinueMigrateJob
- Data Sync APIs
- DescribeSyncJobs
- ModifySyncJobConfig
- CreateModifyCheckSyncJob
- DescribeModifyCheckSyncJobResult
- StartModifySyncJob
- CreateSyncJob
- ConfigureSyncJob
- CreateCheckSyncJob
- SkipSyncCheckItem
- DescribeCheckSyncJobResult
- StartSyncJob
- StopSyncJob
- ResumeSyncJob
- ResizeSyncJob
- RecoverSyncJob
- IsolateSyncJob
- DestroySyncJob
- PauseSyncJob
- ContinueSyncJob
- Data Consistency Check APIs
- Data Types
- Error Codes
- DTS API 2018-03-30
- 相关协议
操作场景
数据订阅 Kafka 版支持对消费组进行管理，包括修改密码、删除消费组、修改消费位点 offset 等。
同时，用户在消费管理中可查看 Client ID（显示消费该组数据的客户端 ID）、分区编号、消费点、消费点写入分区时间、消费延迟等信息。
前提条件
注意事项
在同一个消费组中，当有其他 Kafka 客户端正在消费数据时，不支持修改消费位点。
修改消费组密码
1. 登录 DTS 控制台，在左侧导航选择数据订阅，进入数据订阅页面。
2. 在数据订阅列表，选择所需的数据订阅，单击订阅名或操作列的查看订阅详情，进入订阅管理页面。
3. 在订阅管理页面，选择消费管理页，单击操作列的修改密码。
4. 在弹出的对话框，修改密码，单击修改。
删除消费组
1. 登录 DTS 控制台，在左侧导航选择数据订阅，进入数据订阅页面。
2. 在数据订阅列表，选择所需的数据订阅，单击订阅名或操作列的查看订阅详情，进入订阅管理页面。
3. 在订阅管理页面，选择消费管理页，单击操作列的删除。
4. 在弹出的对话框，确认无误后，单击确定。
注意
删除消费组后，该消费组中的消费点位将被删除，但数据订阅中的数据不会被删除，请谨慎操作。
修改消费位点 offset
1. 登录 DTS 控制台，在左侧导航选择数据订阅，进入数据订阅页面。
2. 在数据订阅列表，选择所需的数据订阅，单击订阅名或操作列的查看订阅详情，进入订阅管理页面。
3. 在订阅管理页面，选择消费管理页，选择对应的消费组，单击修改 offset。
4. 在弹出的对话框中，选择 offset 对象，单击下一步。
5. 设置消费数据的重置方式，然后单击完成。
从最新位置开始消费：消费位点改为 Kafka 消息的最新位点。
从最开始位置开始消费：消费位点改为 Kafka 消息最开始存储的位点。
按时间点进行消费位置重置：用户输入对应的时间，DTS 找到用户输入时间对应的消费位点，然后改为从该消费位点开始消费。
当用户设置的时间超过 Kafka 消息的时间，消费位点将以 Kafka 消息中的最大位点为准；当用户设置的时间早于 Kafka 消息的时间，消费位点将以 Kafka 消息中的最小位点为准。
是
否
本页内容是否解决了您的问题？