Affichage des abonnements et des statistiques Kafka
Affichez des informations détaillées sur un consommateur Kafka et ses performances, y compris le nombre d’enregistrements ajoutés à la rubrique, le nombre d’enregistrements traités et le nombre d’enregistrements restants à traiter.
Un abonnement est un enregistrement associé à un consommateur. Elle stocke les détails de configuration et de performance du consommateur. Un abonnement est créé lorsqu’un flux Kafka est activé.
- Abonnement Kafka
- Mesures
- Groupes de partitions d’abonnement Kafka
- Journaux des consommateurs
- Statistiques de consommation Kafka
Pour afficher un enregistrement d’abonnement, accédez à . Sélectionnez l’icône d’informations ( 
) pour l’abonnement que vous souhaitez afficher, puis sélectionnez Ouvrir l’enregistrement.
Abonnement Kafka
| Champ | Description |
|---|---|
| Numéro | Numéro de l’enregistrement d’abonnement. |
| État | État du consommateur. Les options sont les suivantes :
|
| Sujet | Rubrique à partir de laquelle le consommateur traite les messages. |
| ID de consommateur | Identificateur unique pour le consommateur. |
| Politique de positionnement automatique Kafka | Spécifie l’endroit où le consommateur commence à lire les messages de la rubrique. Les options sont les suivantes :
|
| Contient une erreur | Indique si l’abonnement comporte des erreurs. |
| Concurrence max. | Nombre maximal de processeurs parallèles utilisés pour consommer des messages et nombre de groupes de partitions. |
| Délai d’expiration du groupe de partitions | Durée maximale, en millisecondes, allouée à chaque groupe de partitions de l’abonnement. |
| Partitions Kafka | Nombre de partitions dans la rubrique. |
| Taille du lot max. | Nombre maximal de messages traités par exécution. Les options sont les suivantes :
|
Mesures
- Taux d’entrée de rubrique : nombre moyen d’enregistrements ajoutés à la rubrique par seconde.
- Taux de traitement du consommateur : nombre moyen d’enregistrements traités par seconde.
- Profondeur de la file d’attente des rubriques : nombre moyen d’enregistrements restant à traiter dans la rubrique.
Groupes de partitions d’abonnement Kafka
| Champ | Description |
|---|---|
| Numéro | Numéro du groupe de partitions. |
| Propriétaire de ce groupe de partitions | État de propriété du groupe de partitions. Les options sont les suivantes :
Lorsqu’une tâche de consommateur Kafka est activée, elle recherche le premier enregistrement mis à jour avec un propriétaire NONE et en sélectionne un. Ensuite, la tâche du consommateur change le propriétaire en TRAITEMENT et le traite pendant 10 secondes. Une fois le traitement terminé, l’état redevient NONE, de sorte qu’il puisse être récupéré et traité à nouveau ultérieurement. Si la tâche du consommateur traite tous les messages, elle définit le propriétaire sur VERROUILLÉ pendant 10 secondes, après quoi elle est à nouveau définie sur AUCUN. |
| Mis à jour | Date et heure de la dernière mise à jour du groupe de partitions. |
| Quand la propriété est-elle perdue ? | Date et heure auxquelles la propriété est perdue. |
| Première partition | Numéro de la première partition pour le groupe de partitions. |
| Dernière partition (incluse) | Numéro de la dernière partition pour le groupe de partitions. |
| Taux d’entrée Donné pour les cinq dernières minutes, la dernière heure et les dernières 24 heures. |
Nombre moyen d’enregistrements ajoutés au groupe de partitions par seconde. |
| Traitement consommateur Donné pour les cinq dernières minutes, la dernière heure et les dernières 24 heures. |
Nombre moyen de messages consommés à partir du groupe de partition par seconde. |
| Profondeur de la file d’attente Donné pour les cinq dernières minutes, la dernière heure et les dernières 24 heures. |
Nombre moyen d’enregistrements restant à traiter dans le groupe de partitions. |
Journaux des consommateurs
L’onglet Journaux des consommateurs affiche les entrées de journal pour le consommateur associé. Elle indique la date de création de chaque entrée, son niveau de journalisation, le message et la source. Les journaux des consommateurs sont stockés dans la table Journaux des consommateurs [sys_consumer_log].
Vous pouvez augmenter le nombre de messages de journal ajoutés aux journaux des consommateurs en activant la glide.ih.kafka.debug.consume propriété.
Statistiques de consommation Kafka
| Champ | Description |
|---|---|
| Date de création | Date et heure de création de l’enregistrement de statistiques sur les consommateurs. |
| Intervalle | Durée de l’enregistrement des statistiques sur les consommateurs, exprimée en secondes. Vous pouvez modifier la longueur de l’intervalle avec la glide.ih.kafka.consumer.log_interval propriété. La valeur par défaut est de 60 secondes. Vous pouvez spécifier si des messages doivent être consignés dans le journal du consommateur lorsqu’aucun message Kafka n’est produit ou consommé pendant l’intervalle avec la glide.ih.kafka.consumer.log_empty_stats propriété. La valeur par défaut est vrai. |
| Messages produits | Nombre de messages produits pour la rubrique pendant l’intervalle. |
| Messages consommés | Nombre de messages traités par le consommateur pendant l’intervalle. |
| Octets consommés | Nombre d’octets traités par le consommateur pendant l’intervalle. |
| Décalage | Somme de tous les décalages pour le groupe de partitions. |
| Messages de retard | Différence entre le décalage de fin et le décalage actuel. |
| Décalage de fin | Somme de tous les décalages de fin pour le groupe de partitions. |
| Groupe de partitions | Enregistrement pour le groupe de partitions. |