Un registre de schémas est un dépôt permettant de gérer les schémas utilisés par vos producteurs et consommateurs Kafka.
Ce document explique comment créer une ressource de registre de schémas dans Managed Service for Apache Kafka à l'aide de la consoleGoogle Cloud , de la Google Cloud CLI ou de l'API Managed Kafka.
Avant de commencer
Avant de créer un registre de schémas, procédez comme suit :
- Créez un cluster Managed Service pour Apache Kafka dans la même région où vous prévoyez de créer un registre de schémas.
Rôles et autorisations nécessaires
Pour obtenir les autorisations nécessaires pour créer un registre de schémas, demandez à votre administrateur de vous accorder le rôle IAM Éditeur du registre de schémas Kafka géré (roles/managedkafka.schemaRegistryEditor) sur votre projet.
Pour en savoir plus sur l'attribution de rôles, consultez Gérer l'accès aux projets, aux dossiers et aux organisations.
Ce rôle prédéfini contient les autorisations requises pour créer un registre de schémas. Pour connaître les autorisations exactes requises, développez la section Autorisations requises :
Autorisations requises
Les autorisations suivantes sont requises pour créer un registre de schémas :
-
Accordez cette autorisation à l'emplacement parent :
managedkafka.schemaRegistries.create
Vous pouvez également obtenir ces autorisations avec des rôles personnalisés ou d'autres rôles prédéfinis.
Les rôles de niveau supérieur, comme Administrateur Managed Service pour Apache Kafka Schema Registry, vous permettent également de créer et de gérer des registres de schémas.
Pour en savoir plus sur les rôles prédéfinis disponibles pour Managed Service pour Apache Kafka, consultez la documentation sur le contrôle des accès.
Créer un registre de schémas
Console
- Dans la console Google Cloud , accédez à la page Registres de schémas.
Accéder aux registres de schémas
La page Registres de schémas s'ouvre.
- Sur la page Registres de schémas, cliquez sur Créer.
La page Créer un registre de schémas s'ouvre.
- Dans le champ Nom du registre de schémas, saisissez un identifiant unique pour votre registre.
Le nom doit commencer par une lettre, ne contenir que des lettres (a-z, A-Z), des chiffres (0-9) et des traits de soulignement (_), et comporter au maximum 63 caractères.
- Sélectionnez ou saisissez une région dans le menu.
Vous devez déjà disposer d'un ou plusieurs clusters Managed Service pour Apache Kafka actifs dans la région spécifiée. Pour vérifier les régions de vos clusters, consultez la documentation sur lister vos clusters.
Pour obtenir la liste des emplacements compatibles, consultez Emplacements Managed Service pour Apache Kafka.
- Cliquez sur Créer.
gcloud
-
Installez la Google Cloud CLI. Une fois que la Google Cloud CLI est installée, initialisez-la en exécutant la commande suivante :
gcloud initSi vous utilisez un fournisseur d'identité (IdP) externe, vous devez d'abord vous connecter à la gcloud CLI avec votre identité fédérée.
- Utilisez la commande
gcloud beta managed-kafka schema-registries createpour créer un registre de schémas :gcloud beta managed-kafka schema-registries create SCHEMA_REGISTRY_ID \ --location=LOCATION \
Remplacez les éléments suivants :
- SCHEMA_REGISTRY_ID (obligatoire) : identifiant unique de votre nouveau registre de schémas. Il fait partie du nom de ressource du registre. Le nom doit commencer par une lettre, ne contenir que des lettres (a-z, A-Z), des chiffres (0-9) et des traits de soulignement (_), et comporter 63 caractères ou moins.
- LOCATION (obligatoire) : région Google Cloud dans laquelle le registre de schémas sera créé. Cet emplacement doit correspondre à la région du ou des clusters Managed Service pour Apache Kafka utilisant ce registre. Pour connaître les régions compatibles, consultez Emplacements Managed Service pour Apache Kafka.
Pour créer un registre de schémas nommé
test_schema_registrydans la régionus-central1, exécutez la commande suivante :gcloud beta managed-kafka schema-registries create test_schema_registry \ --location=us-central1
Une fois la commande exécutée, le registre de schémas est créé. Vous pouvez ensuite configurer les clients Kafka pour qu'ils utilisent son URL. Pour afficher l'URL du registre de schémas, consultez Détails de la page du registre de schémas.
REST
Pour créer une instance de registre de schémas à l'aide de l'API REST, procédez comme suit.
- Envoyez une requête
POSTsemblable à la suivante : - Créez un fichier JSON
request-body.jsonavec la structure suivante : - SCHEMA_REGISTRY_ID (obligatoire) : identifiant unique de votre nouveau registre de schémas. Il fait partie du nom de ressource du registre. Le nom doit commencer par une lettre, ne contenir que des lettres (a-z, A-Z), des chiffres (0-9) et des traits de soulignement (_), et comporter 63 caractères ou moins.
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" }
Remplacez les éléments suivants :
Exécutez la requête POST avec l'URI, les en-têtes et le corps construits. En cas de succès, l'API renvoie un code d'état 200 OK et un corps de réponse contenant la représentation JSON de la ressource SchemaRegistry nouvellement créée.
Voici un exemple de réponse réussie.
{ "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/. représente le contexte par défaut. Les ressources du contexte par défaut ne nécessitent pas de contexte spécifique.
Pour en savoir plus, consultez la documentation sur l'API REST.