eventscore.ext.kafka package¶ Submodules¶ eventscore.ext.kafka.serializers module¶ class KafkaEventSerializer(*args, **kwargs)[source]¶ Bases: IEventSerializer[EventDict, bytes] encode(event)[source]¶ Encode an event Parameters: event (Event) – Event to encode Returns: Encoded event Return type: RType decode(event)[source]¶ Decode an event Parameters: event (IType) – Event to decode Returns: Decoded event Return type: Event eventscore.ext.kafka.streams module¶ class KafkaStream(serializer)[source]¶ Bases: IStream Parameters: serializer (IEventSerializer[EventDict, bytes]) put(event, *, block=True, timeout=5)[source]¶ Put an event to stream Parameters: event (Event) – Event to put block (bool) – Should I/O be blocked if some delay occurs. Defaults to True. timeout (int) – Number of seconds to wait in case of latency. Defaults to 5. Returns: None Return type: None pop(event, group, *, block=True, timeout=5)[source]¶ Pop an event from stream Parameters: event (EventType) – Event type block (bool) – Should I/O be blocked if some delay occurs. Defaults to True. timeout (int) – Number of seconds to wait in case of latency. Defaults to 5. group (str | StrEnum | IntEnum) Returns: Next unprocessed event in stream Return type: Event Module contents¶