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:
- Erstellen Sie einen Managed Service for Apache Kafka-Cluster in derselben Region, in der Sie eine Schema-Registry erstellen möchten.
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
- Rufen Sie in der Google Cloud Console die Seite Schema-Registries auf.
Die Seite Schemaregister wird geöffnet.
- Klicken Sie auf der Seite Schema-Registrierungen auf Erstellen.
Die Seite Schemaregister erstellen wird geöffnet.
- 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.
- 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.
- Klicken Sie auf Erstellen.
gcloud
-
Installieren Sie die Google Cloud CLI. Initialisieren Sie die Google Cloud CLI nach der Installation mit dem folgenden Befehl:
gcloud initWenn Sie einen externen Identitätsanbieter (IdP) verwenden, müssen Sie sich zuerst mit Ihrer föderierten Identität in der gcloud CLI anmelden.
- 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_registryin der Regionus-central1zu 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:
- Senden Sie eine
POST-Anfrage wie die folgende: - Erstellen Sie eine JSON-Datei
request-body.jsonmit der folgenden Struktur: - 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.
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
{ "schemaRegistryId": "SCHEMA_REGISTRY_ID" }
Ersetzen Sie Folgendes:
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.