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