Themen auflisten

Sie können die Themen in einer bestimmten Schemaregistrierung oder einem bestimmten Kontext in Ihrem Projekt auflisten.

In diesem Dokument wird beschrieben, wie Sie Themen mit derGoogle Cloud Console oder der Managed Kafka API auflisten.

Erforderliche Rollen und Berechtigungen

Bitten Sie Ihren Administrator, Ihnen die IAM-Rolle Managed Kafka Schema Registry Viewer (roles/managedkafka.schemaRegistryViewer) für Ihre Schemaregistrierung oder Ihren Kontext zuzuweisen, um die Berechtigungen zu erhalten, die Sie zum Auflisten von Themen benötigen. Weitere Informationen zum Zuweisen von Rollen finden Sie unter Zugriff auf Projekte, Ordner und Organisationen verwalten.

Diese vordefinierte Rolle enthält die Berechtigungen, die zum Auflisten von Themen erforderlich sind. Maximieren Sie den Abschnitt Erforderliche Berechtigungen, um die notwendigen Berechtigungen anzuzeigen:

Erforderliche Berechtigungen

Die folgenden Berechtigungen sind erforderlich, um Themen aufzulisten:

  • Gewähren Sie die folgende Berechtigung für die übergeordnete Schemaregistrierung oder den übergeordneten Kontext: managedkafka.googleapis.com/subjects.list

Sie können diese Berechtigungen auch mit benutzerdefinierten Rollen oder anderen vordefinierten Rollen erhalten.

Weitere Informationen zu vordefinierten Rollen finden Sie unter Vordefinierte Rollen für Managed Service for Apache Kafka.

Subjekte in einer Schema-Registry auflisten

So listen Sie alle Themen in einer bestimmten Schemaregistrierung oder einem bestimmten Kontext in Ihrem Projekt auf:

Console

  1. Rufen Sie in der Google Cloud Console die Seite Schema-Registries auf.

    Zu Schemaregistrierungen

  2. Klicken Sie auf den Namen der Schemaregistrierung, deren Details Sie aufrufen möchten.

  3. Auf der Seite Details zur Schema-Registry werden die Subjekte unter Subjekte in dieser Schema-Registry aufgeführt.

  4. Optional: Wenn Sie filtern möchten, welche Themen angezeigt werden, klicken Sie auf Filter . Sie können nach den folgenden Attributen filtern:

    • Name
    • Kontext
    • Vorläufig gelöscht (Ja/Nein)

  5. Optional: Wenn Sie Spalten ein- oder ausblenden möchten, klicken Sie auf  Spaltenanzeigeoptionen und wählen Sie die Spalten aus, die ein- oder ausgeblendet werden sollen.

REST

Die Anfrage muss mit einem Zugriffstoken im Header Authorization authentifiziert werden. So rufen Sie ein Zugriffstoken für die aktuellen Standardanmeldedaten für Anwendungen ab: gcloud auth application-default print-access-token.

Wenn Sie Themen direkt unter einer Schemaregistrierung auflisten möchten, senden Sie eine GET-Anfrage an den entsprechenden URI mit der Methode projects.locations.schemaRegistries.schemas.subjects.list für den Standardkontext.

GET https://managedkafka.googleapis.com/v1main/projects/PROJECT_ID/locations/LOCATION/schemaRegistries/REGISTRY_ID/subjects
Authorization: Bearer $(gcloud auth application-default print-access-token)

Wenn Sie die Themen unter einem Kontext in einer Schemaregistrierung auflisten möchten, senden Sie eine GET-Anfrage an den entsprechenden URI mit der Methode projects.locations.schemaRegistries.contexts.schemas.subjects.list:

GET https://managedkafka.googleapis.com/v1main/projects/PROJECT_ID/locations/LOCATION/schemaRegistries/REGISTRY_ID/contexts/CONTEXT_ID/subjects?subjectPrefix=SUBJECT_PREFIX
Authorization: Bearer $(gcloud auth application-default print-access-token)

Ersetzen Sie Folgendes:

  • PROJECT_ID (erforderlich): Ihre Google Cloud-Projekt-ID.

  • LOCATION (erforderlich): Die Google Cloud Region, in der sich die Schemaregistrierung befindet.

  • REGISTRY_ID (erforderlich): Die ID Ihrer Schemaregistrierung.

  • CONTEXT_ID (optional): Die ID des Kontexts (wenn Themen in einem Kontext aufgeführt werden).

  • SUBJECT_PREFIX (optional): Der Kontext, nach dem die Themen gefiltert werden sollen, im Format :.{context}:. Wenn nicht festgelegt, werden alle Subjekte in der Registrierung zurückgegeben. Wenn der Wert auf einen leeren String gesetzt ist, werden Themen im Standardkontext aufgelistet.

Bei einer erfolgreichen Anfrage gibt die API den Statuscode 200 OK zurück. Der Antworttext enthält ein JSON-Array mit Betreffnamen.

Das Folgende ist ein Beispiel für eine erfolgreiche Antwort mit Themen in einem JSON-Array für den Standardkontext:

[
  "orders-topic-key",
  "orders-topic-value",
  "user-profile-event"
]

Themen in nicht standardmäßigen Kontexten werden im Format :.context:subject zurückgegeben.

Weitere Informationen finden Sie in der Dokumentation zur Methode projects.locations.schemaRegistries.contexts.schemas.subjects/list.

Nächste Schritte

Apache Kafka® ist eine eingetragene Marke der Apache Software Foundation oder deren Tochtergesellschaften in den USA und/oder anderen Ländern.