Rubriques de surveillance dans le Hermes cluster Kafka
Surveillez le traitement des messages et affichez les Hermes rubriques du cluster Kafka qui vous appartiennent à l’aide de l’inspecteur de Service de messagerie Hermes rubriques.
Suivi des messages dans les partitions
Vous pouvez suivre les messages dans le Hermes cluster Kafka en affichant les informations de partition.
- Déterminez si vos messages atteignent la Hermes grappe Kafka en vérifiant si la valeur du décalage de fin change lorsque vous produisez des messages pour une rubrique.
- Déterminez si les messages ont expiré en notant la valeur du décalage de début, qui augmente à mesure que les messages expirent. Si vous envoyez des messages à une rubrique mais que le décalage de début est plus élevé que prévu, cela signifie que certains messages ont déjà expiré. Les messages expirent dans le cluster Kafka au bout de Hermes 36 heures.
Suivi de la progression des consommateurs
Vous pouvez suivre la progression du traitement des messages pour chaque consommateur en consultant les informations sur le consommateur.
- Affichez les consommateurs de chaque partition d’une rubrique, y compris l’ID de groupe et l’ID de consommateur de chaque consommateur.
- Déterminez le message qu’un consommateur traite en affichant la colonne Décalage actuel .
- Déterminez si le consommateur est retardé en vérifiant la colonne Retard . Le décalage est la différence entre le décalage actuel et le décalage de fin qui indique le nombre de messages restants.
Inspecter les détails du message
Vous pouvez détecter les problèmes liés à la consommation de messages à l’aide de l’inspecteur de rubriques. Par exemple, si un message que vous avez généré n’est pas consommé à partir du cluster Kafka, vous pouvez valider la charge utile et la clé du Hermes message en inspectant la rubrique. Vous pouvez également télécharger l’intégralité de la charge utile et l’enregistrer sous forme de fichier sur votre ordinateur local.
Vous pouvez afficher les messages sous forme de données binaires en codage base-64 au lieu de chaînes UTF8 en ajoutant une propriété système. Consultez Propriétés du Service de messagerie Hermes.