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 restant à traiter.
Un abonnement est un enregistrement associé à un consommateur. Il 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 des consommateurs Kafka
Pour afficher un enregistrement d’abonnement, accédez à . Sélectionnez l’icône d’informations (icône 
) de l’abonnement que vous souhaitez afficher, puis sélectionnez Ouvrir l’enregistrement.
Abonnement Kafka
| Champ | Description |
|---|---|
| Numéro | Numéro de l’enregistrement de l’abonnement. |
| État | État du consommateur. Les options sont les suivantes :
|
| Rubrique | 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’emplacement 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 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 la rubrique : nombre moyen d’enregistrements ajoutés à la rubrique par seconde.
- Vitesse de traitement du consommateur : nombre moyen d’enregistrements traités par seconde.
- Profondeur de la file d’attente de la rubrique : 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 l’enregistrement mis à jour le plus tôt avec un propriétaire de 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 est redéfini sur NONE, de sorte qu’il peut être récupéré et traité à nouveau plus tard. 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 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 du groupe de partitions. |
| Débit 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 de consommateurs 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 partitions 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 du consommateur affiche les entrées de journal du 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 du journal ajoutés aux journaux des consommateurs en activant la glide.ih.kafka.debug.consume propriété.
Statistiques des consommateurs Kafka
| Champ | Description |
|---|---|
| Créées | Date et heure de création de l’enregistrement des 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 s’il faut consigner les messages dans le journal des consommateurs 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 dans la rubrique pendant l’intervalle de temps. |
| Messages consommés | Nombre de messages traités par le consommateur pendant l’intervalle de temps. |
| 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. |