Aller au contenu
uencoder

Protobuf Stream

Le streaming Protobuf concatène plusieurs messages Protobuf préfixés par leur longueur, permettant le transport en flux et l'analyse message par message.

Objectif

Transporter plusieurs messages Protobuf sur des flux TCP/gRPC, chaque message étant délimité par un préfixe de longueur varint.

Mécanisme

Chaque message est encodé comme un préfixe de longueur varint suivi des octets Protobuf. Le récepteur lit la longueur varint, lit ce nombre d'octets, analyse un message, puis recommence. Le format de trame gRPC fonctionne ainsi.

Cas d’usage

  • RPC en flux gRPC
  • Messages Protobuf dans Kafka
  • Transport de flux de logs

Outils associés

References