Réinitialise l'offset de consommation d'un groupe de consommateurs. Si vous réinitialisez un offset de consommation, l'offset à partir duquel un consommateur commence à consommer des messages est modifié. Si des erreurs se produisent ou si des messages incorrects sont consommés lors de la consommation des messages, vous pouvez réinitialiser l'offset de consommation pour ramener la consommation à un offset spécifique en vue d'une reconsommation. Vous pouvez également réinitialiser l'offset de consommation au dernier offset et laisser temporairement les messages accumulés non traités.
Testez maintenant
Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale. Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale.
Test
Autorisation RAM
|
rocketmq:ResetConsumeOffset |
update |
*ConsumerGroup
|
Aucune | Aucune |
Syntaxe de la requête
PATCH /instances/{instanceId}/consumerGroups/{consumerGroupId}/consumeOffsets/{topicName} HTTP/1.1
Paramètres de chemin
|
Paramètre |
Type |
Requis |
Description |
Exemple |
| instanceId |
string |
Oui |
L'identifiant de l'instance. |
rmq-cn-tl32ue44x0g |
| consumerGroupId |
string |
Oui |
L'identifiant du groupe de consommateurs. |
dolphin_status |
| topicName |
string |
Oui |
Le nom du topic. |
AMZN_REPORT_TOPIC |
Paramètres de requête
|
Paramètre |
Type |
Requis |
Description |
Exemple |
| body |
object |
Non |
Le corps de la requête. |
|
| resetType |
string |
Non |
La méthode utilisée pour réinitialiser l'offset de consommation. Valeurs valides : LATEST_OFFSET et SPECIFIED_TIME. Valeurs valides :
|
LATEST_OFFSET |
| resetTime |
string |
Non |
L'heure à laquelle l'offset de consommation est réinitialisé. |
2023-03-22 12:17:08 |
Éléments de réponse
|
Élément |
Type |
Description |
Exemple |
|
object |
Résultat. |
||
| requestId |
string |
L'identifiant de la requête. |
F9A95891-EAD4-5A2B-8A30-676CD18921AF |
| success |
boolean |
Indique si la requête a réussi. |
true |
| code |
string |
Le code d'erreur renvoyé. |
MissingInstanceId |
| message |
string |
Le message d'erreur renvoyé. |
L'instance est introuvable |
| httpStatusCode |
integer |
Le code d'état HTTP renvoyé. |
200 |
| dynamicCode |
string |
Le code d'erreur dynamique renvoyé. |
InstanceId |
| dynamicMessage |
string |
Le message d'erreur dynamique renvoyé. |
instanceId |
Exemples
JSON format
{
"requestId": "F9A95891-EAD4-5A2B-8A30-676CD18921AF",
"success": true,
"code": "MissingInstanceId",
"message": "The instance cannot be found.",
"httpStatusCode": 200,
"dynamicCode": "InstanceId",
"dynamicMessage": "instanceId"
}
Codes d'erreur
Consultez Codes d'erreur pour la liste complète.
Notes de version
Consultez Notes de version pour la liste complète.