Use the update_check_point command to modify the checkpoint of a consumer group - Simple Log Service

コンシューマーグループのシャードのデータ消費チェックポイントを変更します。

リクエスト構文

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	プロジェクト名。
--logstore	String	はい	logstore-a	Logstore 名。
--consumer_group	String	はい	consumer-group-1	コンシューマーグループ名。
--shard	Integer	はい	1	シャード ID。
--check_point	String	はい	MTUyNDE1NTM3OTM3MzkwODQ5Ng==	チェックポイント値。
--consumer	String	いいえ	consumer_1	コンシューマー。
--force_success	Boolean	いいえ	true	更新を強制するかどうかを指定します。 true：更新を強制します。 false：更新を強制しません。

コマンドラインインターフェイス (CLI) のグローバルパラメーターについては、「グローバルパラメーター」をご参照ください。

例

リクエストの例

指定されたコンシューマーグループのシャードのチェックポイントを更新します。

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

レスポンスの例

例

Request example

You can use the default account to modify the timeout for the consumer group 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

If the command is successful, no response is returned. You can run the following command to query the consumer group.

aliyunlog log get_check_point --project="aliyun-test-project" --logstore="logstore-a" --consumer_group="consumer-group-1" --shard=3

The following response is returned:

[
  {
    "checkpoint": "MTUyNDE1NTM3OTM3MzkwODQ5Ng==",
    "consumer": "",
    "shard": 3,
    "updateTime": 1719544024896258
  }
]

エラーコード

エラーメッセージが返された場合は、「UpdateCheckPoint のエラーコード」をご参照ください。

Simple Log Service:update_check_point

リクエスト構文

リクエストパラメーター

例

例

エラーコード

関連 API