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

Modifie le point de contrôle de consommation des données d'un shard pour un groupe de consommateurs.

Syntaxe de la requête

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>]

Paramètres de la requête

Le tableau suivant décrit les paramètres obligatoires et spécifiques à cette commande.

Nom du paramètre	Types numériques	Obligatoire	Valeur d'exemple	Description
--project	String	Oui	aliyun-test-project	Nom du projet.
--logstore	String	Oui	logstore-a	Nom du Logstore.
--consumer_group	String	Oui	consumer-group-1	Nom du groupe de consommateurs.
--shard	Integer	Oui	1	ID du shard.
--check_point	String	Oui	MTUyNDE1NTM3OTM3MzkwODQ5Ng==	Valeur du point de contrôle.
--consumer	String	Non	consumer_1	Consommateur.
--force_success	Boolean	Non	true	Indique s'il faut forcer la mise à jour. true : force la mise à jour. false : ne force pas la mise à jour.

Pour plus d'informations sur les paramètres globaux de l'interface de ligne de commande (CLI), consultez la rubrique Paramètres globaux.

Exemples

Exemple de requête

Vous pouvez mettre à jour le point de contrôle d'un shard pour un groupe de consommateurs spécifique.

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

Si la commande aboutit, aucune réponse n'est renvoyée.Exemple

Exemple de requête

Vous pouvez utiliser le compte par défaut pour modifier le délai d'expiration du groupe de consommateurs 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

Si la commande aboutit, aucune réponse n'est renvoyée. Exécutez la commande suivante pour interroger le groupe de consommateurs.

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

La réponse suivante est renvoyée :

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

Codes d'erreur

En cas de message d'erreur, consultez la rubrique Codes d'erreur UpdateCheckPoint pour plus d'informations.

Référence API

UpdateCheckPoint