Affichage des abonnements et des statistiques Kafka

Rversion finale: Zurich

Mis à jour 31 juil. 2025

5 minutes de lecture

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é.

Chaque page d’abonnement comprend les sections suivantes.

Abonnement Kafka
Mesures
Groupes de partitions d’abonnement Kafka
Connexion au flux Journaux
Statistiques des consommateurs Kafka

Pour afficher un enregistrement d’abonnement, accédez à Centre d'intégration > Connexion au flux > Abonnements. Sélectionnez l’icône d’informations (icône ) de l’abonnement que vous souhaitez afficher, puis sélectionnez Ouvrir l’enregistrement.

Abonnement Kafka

La section Abonnement Kafka affiche les détails de configuration pour le consommateur et l’abonnement.


Champ	Description
Numéro	Numéro de l’enregistrement de l’abonnement.
État	État du consommateur. Les options sont les suivantes : ACTIVE REFRESHING STOPPING
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’emplacement où le consommateur commence à lire les messages de la rubrique. Les options sont les suivantes : Le plus tôt : le consommateur commence à lire le premier message disponible dans la rubrique. le plus récent : le consommateur lit uniquement les messages transmis à la rubrique après le démarrage du consommateur.
Format de sérialisation	Format de sérialisation du message. Les options sont les suivantes : Texte brut Codé
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 : automatiquement optimisé : le système choisit le nombre de messages. un nombre : l’utilisateur sélectionnait manuellement un nombre.

Mesures

Chaque mesure est mesurée sur trois intervalles de temps : les cinq minutes précédentes, l’heure précédente et les 24 heures précédentes.

Taux d’entrée de la rubrique : nombre moyen d’enregistrements ajoutés à la rubrique par seconde.
Profondeur de la file d’attente de la rubrique : nombre moyen d’enregistrements restant à traiter dans la rubrique.
Vitesse de traitement du consommateur : nombre moyen d’enregistrements traités par seconde. La durée estimée de traitement de la file d’attente actuelle affiche le temps nécessaire pour traiter les messages actuellement dans la file d’attente. Elle est calculée en fonction de la profondeur de la file d’attente et du taux de traitement du consommateur. L’estimation temporelle est au format HH :MM :SS.

Liens connexes

Affichez l’enregistrement du consommateur qui traite les messages en sélectionnant Ouvrir l’enregistrement de traitement du consommateur.

Groupes de partitions d’abonnement Kafka

L’onglet Groupes de partitions d’abonnement Kafka affiche les détails suivants.


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 : AUCUN : Le groupe de partitions n’est détenu par aucune tâche de consommateur Kafka. Il peut être récupéré et traité. PROCESSING : le groupe de partitions appartient à une tâche de consommateur Kafka et traite les messages. LOCKED : Le groupe de partitions n’appartient pas à une tâche de consommateur Kafka et n’est pas disponible pour être récupéré. 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.

Connexion au flux Journaux

L’onglet Connexion au flux Journaux affiche les entrées de journal pour le consommateur associé. Chaque entrée de journal indique quand elle a été créée ; son niveau, son message et sa source ; et des liens vers tous les enregistrements d’alerte ou d’abonnement connexes. Connexion au flux journaux sont stockés dans le Connexion au flux Table Journaux [sys_consumer_log].

Vous pouvez activer une journalisation plus détaillée dans les Connexion au flux journaux en ajoutant la propriété système glide.ih.kafka.stream_connect.debug et en la définissant sur vrai. Pour éviter de remplir les journaux, cette propriété est automatiquement désactivée au bout de 24 heures. Si vous avez besoin d’une journalisation détaillée pendant plus de 24 heures, vous pouvez réactiver la propriété manuellement.

Statistiques des consommateurs Kafka

L’onglet Statistiques du consommateur Kafka affiche les détails suivants.


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.