eventscore.ext.kafka package¶

Submodules¶

eventscore.ext.kafka.serializers module¶

class eventscore.ext.kafka.serializers.KafkaEventSerializer(*args, **kwargs)[source]¶

Bases: IEventSerializer[EventDict, bytes]

decode(event: EventDict) → Event[source]¶

Decode an event

Parameters:: event (IType) – Event to decode
Returns:: Decoded event
Return type:: Event

encode(event: Event) → bytes[source]¶

Encode an event

Parameters:: event (Event) – Event to encode
Returns:: Encoded event
Return type:: RType

eventscore.ext.kafka.streams module¶

Module contents¶