Schema-Registry erstellen

Eine Schema-Registry ist ein Repository zum Verwalten von Schemata, die von Ihren Kafka-Produzenten und ‑Nutzern verwendet werden.

In diesem Dokument wird beschrieben, wie Sie mit derGoogle Cloud Console, der Google Cloud CLI oder der Managed Kafka API eine Schemaregisterressource in Managed Service for Apache Kafka erstellen.

Hinweise

Führen Sie vor dem Erstellen einer Schemaregistrierung die folgenden Schritte aus:

Erforderliche Rollen und Berechtigungen

Bitten Sie Ihren Administrator, Ihnen die IAM-Rolle Managed Kafka Schema Registry Editor (roles/managedkafka.schemaRegistryEditor) für Ihr Projekt zuzuweisen, um die Berechtigungen zu erhalten, die Sie zum Erstellen einer Schemaregistrierung 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 Erstellen einer Schemaregistrierung erforderlich sind. Maximieren Sie den Abschnitt Erforderliche Berechtigungen, um die notwendigen Berechtigungen anzuzeigen:

Erforderliche Berechtigungen

Die folgenden Berechtigungen sind zum Erstellen einer Schemaregistrierung erforderlich:

  • Erteilen Sie diese Berechtigung für den übergeordneten Standort: managedkafka.schemaRegistries.create

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

Mit Rollen auf höherer Ebene wie Managed Kafka Schema Registry Admin können Sie auch Schema-Registries erstellen und verwalten.

Weitere Informationen zu den vordefinierten Rollen, die für Managed Service for Apache Kafka verfügbar sind, finden Sie in der Dokumentation zur Zugriffssteuerung.

Schema-Registry erstellen

Console

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

    Zu Schema-Registries

    Die Seite Schemaregister wird geöffnet.

  2. Klicken Sie auf der Seite Schema-Registrierungen auf Erstellen.

    Die Seite Schemaregister erstellen wird geöffnet.

  3. Geben Sie unter Schema registry name (Name der Schemaregistrierung) eine eindeutige ID für Ihre Registrierung ein.

    Der Name muss mit einem Buchstaben beginnen, darf nur Buchstaben (a–z, A–Z), Ziffern (0–9) und Unterstriche (_) enthalten und darf maximal 63 Zeichen lang sein.

  4. Wählen Sie im Menü eine Region aus oder geben Sie eine ein.

    Sie müssen bereits einen oder mehrere aktive Managed Service for Apache Kafka-Cluster in der angegebenen Region haben. Informationen zum Prüfen der Regionen Ihrer Cluster finden Sie in der Dokumentation zum Auflisten Ihrer Cluster.

    Eine Liste der unterstützten Standorte finden Sie unter Managed Service for Apache Kafka-Standorte.

  5. Klicken Sie auf Erstellen.

gcloud

  1. Installieren Sie die Google Cloud CLI. Initialisieren Sie die Google Cloud CLI nach der Installation mit dem folgenden Befehl:

    gcloud init

    Wenn Sie einen externen Identitätsanbieter (IdP) verwenden, müssen Sie sich zuerst mit Ihrer föderierten Identität in der gcloud CLI anmelden.

  2. Verwenden Sie den Befehl gcloud beta managed-kafka schema-registries create, um eine Schemaregistrierung zu erstellen:

    gcloud beta managed-kafka schema-registries create SCHEMA_REGISTRY_ID \
        --location=LOCATION \

    Ersetzen Sie Folgendes:

    • SCHEMA_REGISTRY_ID (erforderlich): eine eindeutige Kennung für Ihre neue Schemaregistrierung. Dies ist Teil des Ressourcennamens der Registrierung. Der Name muss mit einem Buchstaben beginnen, darf nur Buchstaben (a–z, A–Z), Ziffern (0–9) und Unterstriche (_) enthalten und darf maximal 63 Zeichen lang sein.
    • LOCATION (erforderlich): Die Google Cloud Region, in der die Schemaregistrierung erstellt wird. Dieser Standort muss mit der Region des Managed Service for Apache Kafka-Clusters oder der Cluster übereinstimmen, in denen diese Registry verwendet wird. Eine Liste der unterstützten Standorte finden Sie unter Managed Service for Apache Kafka-Standorte.

    Führen Sie den folgenden Befehl aus, um eine Schemaregistry mit dem Namen test_schema_registry in der Region us-central1 zu erstellen:

    gcloud beta managed-kafka schema-registries create test_schema_registry \
        --location=us-central1

    Nach erfolgreicher Ausführung des Befehls wird die Schema-Registry erstellt. Anschließend können Sie Kafka-Clients so konfigurieren, dass sie die URL verwenden. Die URL der Schema-Registry finden Sie unter Details der Schema-Registry-Seite.

REST

So erstellen Sie eine Schemaregisterinstanz mit der REST API:

  1. Senden Sie eine POST-Anfrage wie die folgende:
  2. POST https://managedkafka.googleapis.com/v1main/projects/PROJECT_ID/locations/LOCATION/schemaRegistries
    Authorization: Bearer $(gcloud auth application-default print-access-token)
    Content-Type: application/json --data @response-body.json
    
  3. Erstellen Sie eine JSON-Datei request-body.json mit der folgenden Struktur:
  4. {
      "schemaRegistryId": "SCHEMA_REGISTRY_ID"
    }

    Ersetzen Sie Folgendes:

    • SCHEMA_REGISTRY_ID (erforderlich): eine eindeutige Kennung für Ihre neue Schemaregistrierung. Dies ist Teil des Ressourcennamens der Registrierung. Der Name muss mit einem Buchstaben beginnen, darf nur Buchstaben (a–z, A–Z), Ziffern (0–9) und Unterstriche (_) enthalten und darf maximal 63 Zeichen lang sein.

    Führen Sie die POST-Anfrage mit dem erstellten URI, den Headern und dem Text aus. Bei Erfolg gibt die API den Statuscode 200 OK und einen Antworttext mit der JSON-Darstellung der neu erstellten SchemaRegistry-Ressource zurück.

    Hier ist ein Beispiel für eine erfolgreiche Antwort.

    {
      "name": "projects/testing-311516/locations/us-central1/schemaRegistries/test",
      "contexts": [
        "projects/testing-311516/locations/us-central1/schemaRegistries/test/contexts/."
      ]
    }

    projects/testing-311516/locations/us-central1/schemaRegistries/test/contexts/. steht für den Standardkontext. Für Ressourcen im Standardkontext muss kein Kontext angegeben werden.

    Weitere Informationen finden Sie in der REST API-Dokumentation.

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

Nächste Schritte