bytewax.connectors.kafka.serde

Serializers and deserializers for kafka messages.

Data

logger

‘getLogger(…)’

SerdeOut: TypeVar

SerdeIn: TypeVar

Classes

class SchemaSerializer

Bases:

• ABC

• Generic[SerdeIn, SerdeOut]

A serializer for a specific schema.

abstract ser(

obj: SerdeIn,

) → SerdeOut

Serialize an object.

class SchemaDeserializer

Bases:

• ABC

• Generic[SerdeIn, SerdeOut]

A deserializer for a specific schema.

abstract de(

data: SerdeIn,

) → SerdeOut

Deserialize data.