Aplicación de esquemas del lado cliente

La aplicación del esquema del lado cliente garantiza que los datos se validen con los esquemas definidos en el registro de esquemas en el lado cliente, en lugar de en el lado del servidor o bróker. La aplicación de productor puede usar esquemas para validar y serializar datos antes de enviar los datos a un centro de eventos. Del mismo modo, una aplicación de consumidor puede deserializar y validar los datos después de recibir eventos de un centro de eventos.

El cumplimiento del esquema del lado cliente garantiza que los datos se validen en el lado cliente. La aplicación de productor envía los datos y la aplicación de consumidor la recibe. Esos datos se validan con esquemas definidos en el registro de esquemas en el lado cliente en lugar del lado agente o servidor.

En este diagrama se muestra el flujo:

Nota:

En el diagrama se muestra el flujo de información cuando los productores y consumidores de eventos usan un registro de esquema con el protocolo Kafka y el esquema Avro. Otros protocolos y formatos de esquema funcionan de forma similar.

Productor

1. La aplicación de productor de Kafka usa KafkaAvroSerializer para serializar los datos de eventos mediante el esquema especificado. La aplicación de productor proporciona detalles del punto de conexión del registro de esquema y otros parámetros opcionales necesarios para la validación del esquema.

2. El serializador busca el esquema en el registro de esquema para serializar los datos de eventos. Si encuentra el esquema, se devuelve el identificador de esquema correspondiente. Puede configurar la aplicación del productor para registrar automáticamente el esquema con el registro de esquemas si no existe.

3. A continuación, el serializador antepone el identificador de esquema a los datos serializados que se publican en Event Hubs.

Consumidor

1. La aplicación de consumidor Kafka usa KafkaAvroDeserializer para deserializar los datos que recibe del centro de eventos.

2. El deserializador usa el identificador del esquema (añadido antes por el productor) para recuperar el esquema del registro de esquemas.

3. El deserializador usa el esquema para deserializar los datos de eventos que recibe del centro de eventos.

4. El cliente del registro de esquema usa el almacenamiento en caché para evitar búsquedas redundantes del registro de esquema en el futuro.