OnsConsumerResetOffset - - Centre de documentation Alibaba Cloud

Remarque

Appelez cette opération pour purger les messages en attente ou les retraiter. Pour purger les messages en attente, utilisez l'une des méthodes suivantes :

Purgez tous les messages en attente dans une rubrique donnée.
Purgez les messages publiés dans la rubrique donnée avant un instant précis.

Limite de requêtes

Chaque compte Alibaba Cloud peut appeler cette opération jusqu'à 10 fois par seconde. Si le nombre de requêtes envoyées en une seconde atteint cette limite, les nouvelles requêtes échouent, ce qui peut interrompre votre activité. Pour connaître les limites de requêtes de chaque opération, consultez la section Limites des requêtes API.

Autorisation

Par défaut, les comptes Alibaba Cloud peuvent appeler cette opération. Un utilisateur RAM (Resource Access Management) ne peut l'appeler qu'après avoir reçu les autorisations nécessaires. Le tableau ci-dessous décrit les autorisations à accorder à un utilisateur RAM pour appeler cette opération. Pour savoir comment accorder des autorisations, consultez la section Stratégies.

API

Action

Ressource dans une instance utilisant un namespace

Ressource dans une instance n'utilisant pas de namespace

OnsConsumerResetOffset

mq:QueryInstanceBaseInfo

mq:ResetConsumerOffset

acs:mq:::{instanceId}%{topic}

acs:mq:::{topic}

Paramètres de requête

Paramètre	Type	Obligatoire	Exemple	Description
Action	String	Oui	OnsConsumerResetOffset	Opération à effectuer. Définissez la valeur sur OnsConsumerResetOffset.
GroupId	String	Oui	GID_test_consumer_id	ID du groupe de consommateurs dont vous souhaitez réinitialiser l'offset de consommation.
Topic	String	Oui	test-mq-topic	Nom de la rubrique dont vous souhaitez réinitialiser l'offset de consommation.
Type	Integer	Oui	1	Méthode de purge des messages en attente. Valeurs possibles : 0 : Purge tous les messages en attente dans la rubrique spécifiée. Les messages non consommés sont ignorés. Les consommateurs du groupe spécifié consomment uniquement les messages publiés dans la rubrique après l'instant actuel. Si la valeur « reconsumeLater » est renvoyée, les messages en attente ne sont pas purgés car le système réessaie de les envoyer aux consommateurs. 1 : Purge les messages publiés dans la rubrique avant un instant donné. Vous devez spécifier cet instant. Les consommateurs du groupe spécifié consomment uniquement les messages publiés dans la rubrique après cet instant. L'instant spécifié doit se situer entre la première et la dernière publication de message dans la rubrique. Tout instant hors de cette plage est invalide.
ResetTimestamp	Long	Non	1591153871000	Instant auquel réinitialiser l'offset de consommation. Ce paramètre prend effet uniquement si le paramètre Type est défini sur 1. Unité : millisecondes.
InstanceId	String	Oui	MQ_INST_111111111111_DOxxxxxx	ID de l'instance Message Queue for Apache RocketMQ contenant le groupe de consommateurs spécifié.

Paramètres de réponse

Paramètre	Type	Exemple	Description
RequestId	String	D52C68F8-EC5D-4294-BFFF-1A6A25AF****	ID de la requête. Le système génère un ID unique pour chaque requête. Vous pouvez résoudre les problèmes en vous basant sur cet ID.

Exemples

Exemple de requête

http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerResetOffset
&GroupId=GID_test_consumer_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&Topic=test-mq-topic
&Type=1
&ResetTimestamp=1591153871000
&<Common request parameters>

Exemple de réponse réussie

XML format

HTTP/1.1 200 OK
Content-Type:application/xml

<OnsConsumerResetOffsetResponse>
    <RequestId>D52C68F8-EC5D-4294-BFFF-1A6A25AF****</RequestId>
</OnsConsumerResetOffsetResponse>

JSON format

HTTP/1.1 200 OK
Content-Type:application/json

{
  "RequestId" : "D52C68F8-EC5D-4294-BFFF-1A6A25AF****"
}

Codes d'erreur

Pour obtenir la liste des codes d'erreur, visitez le Centre d'erreurs API.

Réinitialiser l'offset de consommation d'un groupe de consommateurs dans la console

Dans la console Message Queue for Apache RocketMQ, vous pouvez réinitialiser l'offset pour un groupe de consommateurs. Pour plus d'informations, consultez la section Réinitialiser les offsets des consommateurs.