Rubriques de surveillance dans la Hermes grappe Kafka
Surveillez le traitement des messages et affichez les rubriques de la Hermes grappe Kafka qui vous appartiennent à l’aide de l’inspecteur Service de messagerie Hermes de rubrique.
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 créez des messages pour une rubrique.
- Déterminez si les messages ont expiré en notant la valeur de décalage de début, qui augmente au fur et à 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, certains messages ont déjà expiré. Les messages expirent dans le cluster Kafka au bout de Hermes 36 heures.
Suivre la progression des consommateurs
Vous pouvez suivre la progression du traitement des messages pour chaque consommateur en consultant les informations de consommateur.
- Affichez les consommateurs pour chaque partition d’une rubrique, y compris l’ID de groupe et l’ID de consommateur pour chaque consommateur.
- Déterminez le message qu’un consommateur traite en affichant la colonne Décalage actuel .
- Déterminez si le consommateur est en retard en consultant la colonne Latence . 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 rubrique. Par exemple, si un message que vous avez produit n’est pas consommé à partir du cluster Kafka, vous pouvez valider la charge utile et la clé de Hermes message en inspectant la rubrique. Vous pouvez également télécharger la charge utile complète et l’enregistrer sous forme de fichier sur votre ordinateur local.
Vous pouvez afficher les messages en tant que données binaires dans un codage base-64 au lieu de chaînes UTF8 en ajoutant une propriété système. Consultez Propriétés Service de messagerie Hermes.