The Faust project is no longer active. This project has been archived.

This package is a plugin for the stream processing framework Faust. It provides a codec to serialize and deserialize Faust models using Flatbuffers.

Warning

This package is highly experimental. Do not use it in production systems.

Usage

import faust
from faust_codec_flatbuffers import FlatbuffersCodec

class Point(faust.Record):
    x: int
    y: int

faust.serializers.codecs.register('point', FlatbuffersCodec.from_model(Point))