Partitions de rubriques

Les événements sont stockés dans une ou plusieurs partitions au sein d’une rubrique. La division d’une rubrique en partitions permet de répartir la charge de traitement entre plusieurs courtiers du Hermes cluster Kafka. Chaque courtier peut gérer les messages provenant de différentes partitions de la même rubrique, ce qui garantit qu’aucun courtier unique n’est responsable du traitement de tous les messages d’une même rubrique. Cette distribution améliore l’évolutivité et la tolérance aux pannes.

Les événements d’une partition sont immuables. Un événement ne peut pas écraser un autre événement dans la même partition. Si le même événement est envoyé plusieurs fois à une partition, il est ajouté à la liste des événements de la partition.

Suivi des messages dans les partitions

Vous pouvez suivre les messages dans le cluster Kafka en affichant les Hermes informations de partition.

• Déterminez si vos messages atteignent la Hermes grappe Kafka en vérifiant si la valeur de décalage de fin change lorsque vous produisez des messages pour une rubrique.
• Déterminez si les messages ont expiré en notant la valeur de 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, certains messages ont déjà expiré. Les messages expirent dans le Hermes cluster Kafka après 36 heures.

Suivi de la progression du consommateur

Vous pouvez suivre la progression du traitement des messages pour chaque consommateur en consultant les informations sur les consommateurs.

• 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 retardé en vérifiant la colonne Lag . 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.

Inspection des détails du message

Vous pouvez détecter les problèmes de consommation de messages à l’aide de l’inspecteur de rubriques. Par exemple, si un message que vous avez produit n’est pas utilisé à partir de la Hermes grappe Kafka, vous pouvez valider la charge utile et la clé de message en inspectant la rubrique. Vous pouvez également télécharger la charge utile complète et l’enregistrer en tant que fichier sur votre ordinateur local.

Vous pouvez afficher les messages sous forme de données binaires en codage en base 64 au lieu de chaînes UTF8 en ajoutant une propriété système. Consultez Propriétés système Service de messagerie Hermes.