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.
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))