Crea un registro de esquemas

Un registro de esquemas es un repositorio para administrar los esquemas que utilizan tus productores y consumidores de Kafka.

En este documento, se muestra cómo crear un recurso de registro de esquemas en Managed Service para Apache Kafka con la consola deGoogle Cloud , Google Cloud CLI o la API de Managed Kafka.

Antes de comenzar

Antes de crear un registro de esquema, completa los siguientes pasos:

Roles y permisos requeridos

Para obtener los permisos que necesitas para crear un registro de esquemas, pídele a tu administrador que te otorgue el rol de IAM Editor del registro de esquemas de Kafka administrado (roles/managedkafka.schemaRegistryEditor) en tu proyecto. Para obtener más información sobre cómo otorgar roles, consulta Administra el acceso a proyectos, carpetas y organizaciones.

Este rol predefinido contiene los permisos necesarios para crear un registro de esquemas. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:

Permisos necesarios

Se requieren los siguientes permisos para crear un registro de esquemas:

  • Otorga este permiso en la ubicación principal: managedkafka.schemaRegistries.create

También puedes obtener estos permisos con roles personalizados o con otros roles predefinidos.

Crea un registro de esquemas

Console

  1. En la consola Google Cloud , ve a la página Registros de esquemas.

    Ir a los registros de esquemas

    Se abrirá la página Registros de esquemas.

  2. En la página Registros de esquemas, haz clic en Crear.

    Se abrirá la página Crear registro de esquema.

  3. En Nombre del registro de esquema, ingresa un identificador único para tu registro.

    El nombre debe comenzar con una letra, contener solo letras (a-z, A-Z), números (0-9) y guiones bajos (_) y tener 63 caracteres o menos.

  4. Selecciona o ingresa una región en el menú.

    Ya debes tener uno o varios clústeres activos de Managed Service para Apache Kafka en la región especificada. Para verificar las regiones de tus clústeres, consulta la documentación sobre cómo listar tus clústeres.

    Para ver una lista de las ubicaciones compatibles, consulta las ubicaciones de Managed Service para Apache Kafka.

  5. Haz clic en Crear.

gcloud

  1. Instala Google Cloud CLI. Después de la instalación, inicializa Google Cloud CLI con el siguiente comando: 

    gcloud init

    Si usas un proveedor de identidad externo (IdP), primero debes acceder a la gcloud CLI con tu identidad federada.

  2. Usa el comando gcloud beta managed-kafka schema-registries create para crear un registro de esquemas:

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

    Reemplaza lo siguiente:

    • SCHEMA_REGISTRY_ID (obligatorio): Es un identificador único para tu nuevo registro de esquema. Esto forma parte del nombre del recurso del registro. El nombre debe comenzar con una letra, contener solo letras (a-z, A-Z), números (0-9) y guiones bajos (_) y tener 63 caracteres o menos.
    • LOCATION (obligatorio): Es la región de Google Cloud en la que se creará el registro de esquemas. Esta ubicación debe coincidir con la región del clúster o los clústeres de Managed Service para Apache Kafka que usan este registro. Para conocer las ubicaciones admitidas, consulta las ubicaciones de Managed Service para Apache Kafka.

    Para crear un registro de esquema llamado test_schema_registry en la región us-central1, ejecuta el siguiente comando:

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

    Una vez que el comando se completa correctamente, se crea el registro de esquemas. Luego, puedes configurar los clientes de Kafka para que usen su URL. Para ver la URL del registro de esquemas, consulta Detalles de la página del registro de esquemas.

REST

Para crear una instancia del registro de esquemas con la API de REST, sigue estos pasos.

  1. Envía una solicitud POST similar a la siguiente:
    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 archivo JSON request-body.json con la siguiente estructura:
    3. {
  "schemaRegistryId": "SCHEMA_REGISTRY_ID"
}

    Reemplaza lo siguiente:

    • SCHEMA_REGISTRY_ID (obligatorio): Es un identificador único para tu nuevo registro de esquema. Esto forma parte del nombre del recurso del registro. El nombre debe comenzar con una letra, contener solo letras (a-z, A-Z), números (0-9) y guiones bajos (_) y tener 63 caracteres o menos.

    Ejecuta la solicitud POST con el URI, los encabezados y el cuerpo construidos. Si la operación se realiza correctamente, la API devuelve un código de estado 200 OK y un cuerpo de respuesta que contiene la representación JSON del recurso SchemaRegistry recién creado.

    A continuación, se muestra un ejemplo de una respuesta correcta.

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

    El projects/testing-311516/locations/us-central1/schemaRegistries/test/contexts/. representa el contexto predeterminado. Los recursos en el contexto predeterminado no requieren que se especifique ningún contexto.

    Para obtener más información, consulta la documentación de la API de REST.

¿Qué sigue?

Apache Kafka® es una marca registrada de The Apache Software Foundation o sus afiliados en Estados Unidos y otros países.