Enumera las versiones del asunto

Puedes enumerar las versiones de un tema dentro de un registro de esquemas específico en tu proyecto.

En este documento, se muestra cómo enumerar las versiones de temas con la Google Cloud consola o la API de Managed Kafka.

Roles y permisos requeridos

Para obtener los permisos que necesitas para enumerar las versiones de temas, pídele a tu administrador que te otorgue el rol de IAM de Visualizador del registro de esquemas de Managed Kafka (roles/managedkafka.schemaRegistryViewer) en tu registro de esquemas. 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 enumerar las versiones de temas. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:

Permisos necesarios

Se requieren los siguientes permisos para enumerar las versiones de temas:

  • Otorga el siguiente permiso en el tema superior: managedkafka.versions.list

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

Enumera las versiones de esquemas en un tema

Para enumerar todas las versiones de un tema en un registro de esquemas específico dentro de tu proyecto, sigue estos pasos.

Console

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

    Ir a Registros de esquemas

  2. Haz clic en el nombre del registro de esquemas en el que se encuentra tu tema.

  3. En Temas en este registro de esquemas, haz clic en el nombre del tema.

  4. En la página Detalles del tema, las versiones de esquemas se enumeran en Todas las versiones.

  5. Opcional: Para ver la definición de esquema de una versión, selecciona la casilla de verificación del ID de la versión. La definición de esquema se muestra en Definición.

  6. Opcional: Para ver las diferencias entre dos versiones de esquemas de este tema, sigue estos pasos:

    1. En Todas las versiones, selecciona las versiones que deseas comparar.
    2. En el área Definición, haz clic en Ver diferencia.

    Las dos definiciones de esquemas se muestran en paralelo, con las adiciones, las eliminaciones y los cambios destacados.

REST

La solicitud debe autenticarse con un token de acceso en el encabezado Authorization. Para obtener un token de acceso para las credenciales predeterminadas actuales de la aplicación, usa el siguiente comando: gcloud auth application-default print-access-token.

Para enumerar las versiones de temas, realiza una solicitud GET al projects.locations.schemaRegistries.subjects.versions.list método.

GET https://managedkafka.googleapis.com/v1main/projects/PROJECT_ID/locations/LOCATION/schemaRegistries/REGISTRY_ID/subjects/SUBJECT_ID/versions
Authorization: Bearer $(gcloud auth application-default print-access-token)

Reemplaza lo siguiente:

  • PROJECT_ID: Es el ID del Google Cloud proyecto de.
  • LOCATION: Es la Google Cloud región en la que se encuentra el registro de esquemas.
  • REGISTRY_ID: Es el ID de tu registro de esquemas.
  • SUBJECT_ID: Es el ID del tema.

Ejemplo:

GET https://managedkafka.googleapis.com/v1main/projects/test-project/locations/us-central1/schemaRegistries/test_registry/subjects/test_subject/versions
Authorization: Bearer $(gcloud auth application-default print-access-token)

O con un contexto:

GET https://managedkafka.googleapis.com/v1main/projects/test-project/locations/us-central1/schemaRegistries/test_registry/contexts/test_context/subjects/test_subject/versions
Authorization: Bearer $(gcloud auth application-default print-access-token)

Aquí:

  • test-project es el ID del proyecto de Google Cloud .
  • us-central1 es la Google Cloud región en la que se encuentra el registro de esquemas.
  • test_registry es el ID de tu registro de esquemas.
  • test_context es el ID del contexto.
  • test_subject es el ID del tema.

Si la solicitud se realiza de forma correcta, la API muestra un código de estado 200 OK. El cuerpo de la respuesta contiene un array JSON de versiones de temas.

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

{
  "versions": [
    {
      "name": "projects/test-project/locations/us-central1/schemaRegistries/test_registry/subjects/test_subject/versions/1",
      "revisionId": "1a2b3c4d",
      "schemaId": "S12345",
      "createTime": "2024-07-15T12:00:00Z",
      "revisionCreateTime": "2024-07-15T12:00:00Z"
    },
    {
      "name": "projects/test-project/locations/us-central1/schemaRegistries/test_registry/subjects/test_subject/versions/2",
      "revisionId": "5e6f7g8h",
      "schemaId": "S67890",
      "createTime": "2024-07-16T14:30:00Z",
      "revisionCreateTime": "2024-07-16T14:30:00Z"
    }
  ]
}

Para obtener más información, consulta la projects.locations.schemaRegistries.subjects.versions.list documentación del método.

¿Qué sigue?

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