Runners

class ObserverRunner(stream_factory, event, group, *consumers, max_events=-1, logger=<RootLogger root (DEBUG)>)

Bases: IRunner

Parameters:

• stream_factory (IStreamFactory)

• event (str | StrEnum | IntEnum)

• group (str | StrEnum | IntEnum)

• consumers (IConsumer)

• max_events (int)

• logger (Logger)

run()

Start runner

Returns:

None

Return type:

None