Crea un registro di schema

Un registro di schema è un repository per la gestione degli schemi utilizzati dai produttori e dai consumatori Kafka.

Questo documento mostra come creare una risorsa del registro di schema all'interno di Managed Service for Apache Kafka utilizzando la consoleGoogle Cloud , Google Cloud CLI o l'API Managed Kafka.

Prima di iniziare

Prima di creare un registro degli schemi, completa le seguenti operazioni:

Ruoli e autorizzazioni richiesti

Per ottenere le autorizzazioni necessarie per creare un registro degli schemi, chiedi all'amministratore di concederti il ruolo IAM Managed Kafka Schema Registry Editor (roles/managedkafka.schemaRegistryEditor) nel progetto. Per saperne di più sulla concessione dei ruoli, consulta Gestisci l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per creare un registro degli schemi. Per vedere quali sono esattamente le autorizzazioni richieste, espandi la sezione Autorizzazioni obbligatorie:

Autorizzazioni obbligatorie

Per creare un registro degli schemi sono necessarie le seguenti autorizzazioni:

  • Concedi questa autorizzazione nella posizione genitore: managedkafka.schemaRegistries.create

Potresti anche ottenere queste autorizzazioni con ruoli personalizzati o altri ruoli predefiniti.

Ruoli di livello superiore come Amministratore del registro di schema Managed Kafka ti consentono anche di creare e gestire i registri di schema.

Per saperne di più sui ruoli predefiniti disponibili per Managed Service per Apache Kafka, consulta la documentazione sul controllo dell'accesso.

Crea un registro di schema

Console

  1. Nella console Google Cloud , vai alla pagina Registri di schemi.

    Vai ai registri di schemi

    Viene visualizzata la pagina Registri di schemi.

  2. Nella pagina Registri di schemi, fai clic su Crea.

    Viene visualizzata la pagina Crea registro di schema.

  3. In Schema registry name (Nome registro schema), inserisci un identificatore univoco per il registro.

    Il nome deve iniziare con una lettera, contenere solo lettere (a-z, A-Z), numeri (0-9) e trattini bassi (_) e avere una lunghezza massima di 63 caratteri.

  4. Seleziona o inserisci una regione dal menu.

    Devi già avere uno o più cluster Managed Service per Apache Kafka attivi nella regione specificata. Per controllare le regioni dei tuoi cluster, consulta la documentazione su come elencare i cluster.

    Per un elenco delle località supportate, consulta le località di Managed Service per Apache Kafka.

  5. Fai clic su Crea.

gcloud

  1. Installa Google Cloud CLI. Dopo l'installazione, inizializza Google Cloud CLI eseguendo il comando seguente: 

    gcloud init

    Se utilizzi un provider di identità (IdP) esterno, devi prima accedere a gcloud CLI con la tua identità federata.

  2. Utilizza il comando gcloud beta managed-kafka schema-registries create per creare un registro di schema:

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

    Sostituisci quanto segue:

    • SCHEMA_REGISTRY_ID (obbligatorio): un identificatore univoco per il nuovo registro degli schemi. Fa parte del nome della risorsa del registro. Il nome deve iniziare con una lettera, contenere solo lettere (a-z, A-Z), numeri (0-9) e trattini bassi (_) e avere una lunghezza massima di 63 caratteri.
    • LOCATION (obbligatorio): la regione Google Cloud in cui verrà creato il registro di schema. Questa località deve corrispondere alla regione del cluster o dei cluster Managed Service per Apache Kafka che utilizzano questo registro. Per le località supportate, consulta Località di Managed Service per Apache Kafka.

    Per creare un registro degli schemi denominato test_schema_registry nella regione us-central1, esegui questo comando:

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

    Una volta completato correttamente il comando, viene creato il registro di schema. Puoi quindi configurare i client Kafka in modo che utilizzino il relativo URL. Per visualizzare l'URL del registro di schemi, consulta la sezione Dettagli della pagina del registro di schemi.

REST

Per creare un'istanza del registro degli schemi utilizzando l'API REST, segui questi passaggi.

  1. Invia una richiesta POST simile alla seguente:
    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
  2. Crea un file JSON request-body.json con la seguente struttura:
    3. {
  "schemaRegistryId": "SCHEMA_REGISTRY_ID"
}

    Sostituisci quanto segue:

    • SCHEMA_REGISTRY_ID (obbligatorio): un identificatore univoco per il nuovo registro degli schemi. Fa parte del nome della risorsa del registro. Il nome deve iniziare con una lettera, contenere solo lettere (a-z, A-Z), numeri (0-9) e trattini bassi (_) e avere una lunghezza massima di 63 caratteri.

    Esegui la richiesta POST con l'URI, le intestazioni e il corpo creati. In caso di esito positivo, l'API restituisce un codice di stato 200 OK e un corpo della risposta contenente la rappresentazione JSON della risorsa SchemaRegistry appena creata.

    Di seguito è riportato un esempio di risposta corretta.

    {
  "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/. rappresenta il contesto predefinito. Le risorse nel contesto predefinito non richiedono la specifica di alcun contesto.

    Per saperne di più, consulta la documentazione dell'API REST.

Apache Kafka® è un marchio registrato di Apache Software Foundation o delle sue affiliate negli Stati Uniti e/o in altri paesi.

Passaggi successivi