调用CLI命令修改消费组消费数据时Shard的checkpoint。
请求语法
aliyunlog log update_check_point --project=<value> --logstore=<value> --consumer_group=<value> --shard=<value> --check_point=<value> [--consumer=<value>] [--force_success=<value>] [--access-id=<value>] [--access-key=<value>] [--sts-token=<value>] [--region-endpoint=<value>] [--client-name=<value>] [--jmes-filter=<value>] [--format-output=<value>] [--decode-output=<value>]
请求参数
该命令的必选和特有参数描述如下。
参数名称 | 数值类型 | 是否必选 | 示例值 | 描述 |
--project | String | 是 | aliyun-test-project | Project名称。 |
--logstore | String | 是 | logstore-a | Logstore名称。 |
--consumer_group | String | 是 | consumer-group-1 | 消费组名称。 |
--shard | Integer | 是 | 1 | Shard ID。 |
--check_point | String | 是 | MTUyNDE1NTM3OTM3MzkwODQ5Ng== | checkpoint值。 |
--consumer | String | 否 | consumer_1 | 消费者。 |
--force_success | Boolean | 否 | true | 是否强制更新。
|
关于该命令的全局参数,请参见全局参数。
示例
请求示例
修改指定消费组消费数据时Shard的checkpoint。
aliyunlog log update_check_point --project="aliyun-test-project" --logstore="logstore-a" --consumer_group="consumer-group-1" --shard=1 --check_point="MTUyNDE1NTM3OTM3MzkwODQ5Ng==" --consumer="consumer_1" --force_success=true
命令执行成功后,无响应消息。
示例
请求示例
使用默认账号修改消费组consumer-group-1的超时时间。
aliyunlog log update_consumer_group --project="aliyun-test-project" --logstore="logstore-a" --consumer_group="consumer-group-1" --timeout="360" --in_order=true
命令执行成功后,无响应消息。您可以执行如下命令查询消费组。
aliyunlog log get_check_point --project="aliyun-test-project" --logstore="logstore-a" --shard=3
返回结果如下:
[ { "checkpoint": "MTUyNDE1NTM3OTM3MzkwODQ5Ng==", "consumer": "", "shard": 3, "updateTime": 1719544024896258 } ]
错误码
如果返回报错信息,请参见具体接口的错误码处理。更多信息,请参见UpdateCheckPoint错误码处理。