Enumera las versiones del asunto

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

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

Roles y permisos requeridos

Para obtener los permisos que necesitas para enumerar versiones de temas, pídele a tu administrador que te otorgue el rol de IAM de Visualizador del registro de esquemas de Kafka administrado (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 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 un tema:

  • Otorga el siguiente permiso en el asunto principal: managedkafka.versions.list

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

Para obtener más información sobre los roles predefinidos, consulta los roles predefinidos de Managed Service para Apache Kafka.

Enumera las versiones del esquema en un tema

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

Console

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

    Ir a Registros de esquemas

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

  3. En Sujetos en este registro de esquemas, haz clic en el nombre del sujeto.

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

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

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

    1. En Todas las versiones, selecciona las versiones que deseas comparar.
    2. En el área Definition, haz clic en View diff.

    Las dos definiciones del esquema se muestran una al lado de la otra, 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 un tema, realiza una solicitud GET al método projects.locations.schemaRegistries.subjects.versions.list.

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 proyecto de Google Cloud .
  • LOCATION: Es la región de Google Cloud 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 asunto.

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 de tu 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 asunto.

Si la solicitud se realiza correctamente, la API devuelve un código de estado 200 OK. El cuerpo de la respuesta contiene un array JSON de versiones del asunto.

A continuación, se muestra un ejemplo de una 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 documentación del método projects.locations.schemaRegistries.subjects.versions.list.

¿Qué sigue?

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