Si un consommateur cesse de traiter des messages en raison d'une exception, vérifiez le dernier offset validé et réinitialisez-le si nécessaire.
Fonctionnement de la validation des offsets
Un offset de consommateur indique la position du prochain message à lire dans une partition. Le broker ne met pas à jour cette position automatiquement : il enregistre uniquement l'offset que le consommateur valide explicitement.
La méthode de validation dépend du SDK client. La plupart des SDK prennent en charge deux méthodes :
| Méthode | Description |
|---|---|
| Validation automatique | Le SDK valide périodiquement l'offset du dernier message consommé plus 1. |
| Validation manuelle | Votre application appelle commit(offsets) pour valider explicitement l'offset du dernier message consommé plus 1. |
Au redémarrage, le consommateur reprend le traitement à partir du dernier offset validé. Connaître la méthode de validation utilisée par votre application vous aide à diagnostiquer les relectures ou les sauts de messages.
Consulter l'offset actuel du consommateur
Pour vérifier le dernier offset validé d'un consommateur :
Ouvrez la page Topic Details du topic cible.
Dans l'onglet Subscriptions, repérez le topic cible et cliquez sur Consumer Details dans la colonne Actions.
Dans le panneau qui s'affiche, consultez l'offset validé du consommateur. Le traitement reprendra à partir de cet offset.
Pour plus de détails, consultez la rubrique Afficher les détails du consommateur.
Réinitialiser l'offset du consommateur
Arrêtez tous les consommateurs du groupe avant de réinitialiser l'offset. Si un consommateur reste actif, il risque de valider un nouvel offset qui écrasera la valeur réinitialisée.
Pour réinitialiser l'offset d'un consommateur :
Ouvrez la page Group Details du groupe de consommateurs cible.
Dans le coin supérieur droit, cliquez sur Reset Consumer Offset.
Dans le panneau Reset Consumer Offset, sélectionnez une méthode de réinitialisation et configurez l'offset cible.
Pour consulter la liste complète des méthodes de réinitialisation et les instructions détaillées, voir la rubrique Réinitialiser les offsets des consommateurs.