Zeigen Sie detaillierte Informationen über einen Kafka-Verbraucher und seine Leistung an, einschließlich der Anzahl der Datensätze, die dem Thema hinzugefügt wurden, der Anzahl der verarbeiteten Datensätze und der Anzahl der verbleibenden Datensätze, die verarbeitet werden sollen.

Ein Abonnement ist ein Datensatz, der einem Verbraucher zugeordnet ist. Er speichert Konfigurations- und Leistungsdetails zum Verbraucher. Ein Abonnement wird erstellt, wenn ein Kafka-Stream aktiviert wird.

Jede Abonnementseite enthält die folgenden Abschnitte.
  • Kafka-Abonnement
  • Metriken
  • Kafka-Abonnement-Partitionsgruppen
  • Stream Connect for Apache Kafka Protokolle
  • Kafka-Verbraucherstatistiken

Um einen Abonnementdatensatz anzuzeigen, navigieren Sie zu IntegrationHub > Stream Connect > Abonnementsan. Wählen Sie das Infosymbol ( Info-Symbol) Für das Abonnement, das Sie anzeigen möchten, wählen Sie dann aus Öffnen Sie Den Datensatz .

Abbildung : 1. Beispielabonnementseite für einen Kafka-Verbraucher
Die Kafka-Abonnementseite mit Abonnementdetails, Metriken und Informationen zu Partitionsgruppen, Verbraucherprotokollen und Verbraucherstatistiken.

Kafka-Abonnement

Der Abschnitt „Kafka-Abonnement“ zeigt Konfigurationsdetails für den Verbraucher und das Abonnement an.
Feld Beschreibung
Anzahl Nummer des Abonnementdatensatzes.
Status Status des Verbrauchers. Die Optionen sind:
  • AKTIV
  • WIRD AKTUALISIERT
  • WIRD GESTOPPT
Thema Thema, aus dem der Verbraucher Nachrichten verarbeitet.
Verbraucher-ID Eindeutiger Bezeichner für den Verbraucher.
Kafka-Richtlinie für automatische Position Gibt an, wo der Verbraucher mit dem Lesen von Nachrichten aus dem Thema beginnt. Die Optionen sind:
  • Frühestens: Der Verbraucher beginnt mit dem Lesen der frühesten verfügbaren Nachricht im Thema.
  • Aktuell: Der Verbraucher liest nur die Nachrichten, die an das Thema gesendet wurden, nachdem der Verbraucher gestartet hat.
Serialisierungsformat Serialisierungsformat für die Nachricht. Die Optionen sind:
  • Nur-Text
  • Codiert
Fehler ausgelöst Gibt an, ob das Abonnement Fehler aufweist.
Max. Gleichzeitigkeit Maximale Anzahl paralleler Prozessoren, die zum Verbrauchen von Nachrichten verwendet werden, und die Anzahl der Partitionsgruppen.
Partitionsgruppen-Timeout Maximale Zeit in Millisekunden, die jeder Partitionsgruppe im Abonnement zugewiesen ist.
Kafka-Partitionen Anzahl der Partitionen im Thema.
Max. Batchgröße Maximale Anzahl von Nachrichten, die pro Ausführung verarbeitet werden. Die Optionen sind:
  • Automatisch optimiert: Das System wählt die Anzahl der Nachrichten aus.
  • Eine Zahl: Der Anwender hat manuell eine Zahl ausgewählt.

Metriken

Jede Metrik wird über drei Zeitintervalle gemessen: Die vorherigen fünf Minuten, die vorherige Stunde und die vorherigen 24 Stunden.
  • Themeneingaberate: Die durchschnittliche Anzahl der Datensätze, die dem Thema pro Sekunde hinzugefügt wurden.
  • Tiefe der Themenwarteschlange: Die durchschnittliche Anzahl der Datensätze, die im Thema noch verarbeitet werden müssen.
  • Verbraucherverarbeitungsrate: Die durchschnittliche Anzahl der pro Sekunde verarbeiteten Datensätze. Die Geschätzte Zeit bis zur Verarbeitung der aktuellen Warteschlange Zeigt die Zeit an, die für die Verarbeitung der Nachrichten erforderlich ist, die sich derzeit in der Warteschlange befinden. Sie wird basierend auf der Warteschlangentiefe und der Verbraucherverarbeitungsrate berechnet. Die Zeitschätzung ist als HH:MM:SS formatiert.

Zugehörige Links

Zeigen Sie den Datensatz für den Verbraucher an, der die Nachrichten verarbeitet, indem Sie auswählen Öffnen Sie den Verbraucherverarbeitungsdatensatz .

Kafka-Abonnement-Partitionsgruppen

Die Registerkarte „Kafka-Abonnementpartitionsgruppen“ zeigt die folgenden Details an.
Feld Beschreibung
Anzahl Nummer für die Partitionsgruppe.
Besitzer dieser Partitionsgruppe Besitzstatus der Partitionsgruppe. Die Optionen sind:
  • KEINE: Die Partitionsgruppe gehört keinem Kafka-Verbraucherauftrag. Es kann abgeholt und verarbeitet werden.
  • VERARBEITUNG: Die Partitionsgruppe gehört einem Kafka-Verbraucherauftrag und verarbeitet Nachrichten.
  • GESPERRT: Die Partitionsgruppe ist nicht im Besitz eines Kafka-Verbraucherauftrags und kann nicht abgeholt werden.

Wenn ein Kafka-Verbraucherauftrag aktiviert ist, sucht er nach dem frühesten aktualisierten Datensatz mit dem Besitzer „KEINE“ und wählt einen aus.

Dann ändert der Verbraucherauftrag den Besitzer in die VERARBEITUNG und verarbeitet ihn 10 Sekunden lang.

Wenn die Verarbeitung abgeschlossen ist, wird der Status wieder in „KEINE“ geändert, sodass er später abgerufen und erneut verarbeitet werden kann.

Wenn der Verbraucherauftrag alle Nachrichten verarbeitet, wird der Besitzer 10 Sekunden lang GESPERRT, danach wird er erneut auf „KEINE“ festgelegt.
Aktualisiert Datum und Uhrzeit der letzten Aktualisierung der Partitionsgruppe.
Wann der Besitz verlorengeht Datum und Uhrzeit des Verlusts des Besitzes.
Erste Partition Nummer der ersten Partition für die Partitionsgruppe.
Letzte Partition (inklusive) Nummer der letzten Partition für die Partitionsgruppe.
Eingaberate

Wird für die letzten fünf Minuten, die letzte Stunde und die letzten 24 Stunden angegeben.

 Durchschnittliche Anzahl der Datensätze, die der Partitionsgruppe pro Sekunde hinzugefügt wurden.
Verbraucherverarbeitung

Wird für die letzten fünf Minuten, die letzte Stunde und die letzten 24 Stunden angegeben.

 Durchschnittliche Anzahl der Nachrichten, die pro Sekunde von der Partitionsgruppe verbraucht werden.
Tiefe der Warteschlange

Wird für die letzten fünf Minuten, die letzte Stunde und die letzten 24 Stunden angegeben.

 Durchschnittliche Anzahl der Datensätze, die in der Partitionsgruppe noch verarbeitet werden sollen.

Stream Connect for Apache Kafka Protokolle

Die Stream Connect for Apache Kafka Auf der Registerkarte Protokolle werden die Protokolleinträge für den zugehörigen Verbraucher angezeigt. Jeder Protokolleintrag zeigt an, wann er erstellt wurde, seine Ebene, Nachricht und Quelle sowie Links zu zugehörigen Warnungs- oder Abonnementdatensätzen. Stream Connect for Apache Kafka Protokolle werden in gespeichert Stream Connect for Apache Kafka Tabelle „Protokolle“ [sys_Consumer_log].

Sie können detailliertere Protokollierung in aktivieren Stream Connect for Apache Kafka Protokolliert nach Systemeigenschaft wird hinzugefügt glide.ih.kafka.stream_connect.debugUnd setzen Sie sie auf Wahr . Um zu vermeiden, dass die Protokolle ausgefüllt werden, wird diese Eigenschaft nach 24 Stunden automatisch deaktiviert. Wenn Sie eine detaillierte Protokollierung für länger als 24 Stunden benötigen, können Sie die Eigenschaft manuell erneut aktivieren.

Kafka-Verbraucherstatistiken

Die Registerkarte Kafka-Verbraucherstatistiken zeigt die folgenden Details an.
Feld Beschreibung
Erstellt Datum und Uhrzeit der Erstellung des Verbraucherstatistikdatensatzes.
Intervall Dauer für den Verbraucherstatistikdatensatz, angegeben in Sekunden.

Sie können die Länge des Intervalls mit ändern glide.ih.kafka.consumer.log_intervalEigenschaft. Der Standardwert beträgt 60 Sekunden.

Sie können angeben, ob Nachrichten im Verbraucherprotokoll protokolliert werden sollen, wenn während des Intervalls mit keine erzeugten oder verbrauchten Kafka-Nachrichten vorhanden sind glide.ih.kafka.consumer.log_empty_statsEigenschaft. Der Standardwert ist „true“.
Erzeugte Nachrichten Anzahl der Nachrichten, die während der Intervallzeit für das Thema erstellt wurden.
Verbrauchte Nachrichten Anzahl der vom Verbraucher während der Intervallzeit verarbeiteten Nachrichten.
Verbrauchte Byte Anzahl der vom Verbraucher während der Intervallzeit verarbeiteten Bytes.
Offset Summe aller Offsets für die Partitionsgruppe.
Verzögerungsnachrichten Differenz zwischen dem Ende-Offset und dem aktuellen Offset.
Ende-Offset Summe aller End-Offsets für die Partitionsgruppe.
Partitionsgruppe Datensatz für die Partitionsgruppe.