Saltar al contenido
uencoder

Protobuf Stream

El streaming de Protobuf concatena múltiples mensajes Protobuf con prefijo de longitud, permitiendo el transporte en flujo y el análisis mensaje a mensaje.

Propósito

Transportar varios mensajes Protobuf sobre flujos TCP/gRPC, delimitando cada mensaje con un prefijo de longitud varint.

Mecanismo

Cada mensaje se codifica como un prefijo de longitud varint más los bytes Protobuf. El receptor lee la longitud varint, lee esos bytes, analiza un mensaje y repite. El formato de tramas de gRPC funciona así.

Casos de uso

  • RPC en flujo de gRPC
  • Mensajes Protobuf en Kafka
  • Transporte de flujos de logs

Herramientas relacionadas

References