papfa.middlewares package¶

Submodules¶

papfa.middlewares.consumer module¶

class papfa.middlewares.consumer.ConsumedMessageStatsMiddleware[source]¶

Bases: ConsumerMiddleware

process_after_flush()[source]¶

process_before_flush(batch: List[Record]) → List[Record][source]¶

class papfa.middlewares.consumer.ConsumerMiddleware[source]¶

Bases: ABC

process_after_flush()[source]¶

process_before_batching(message: Record) → Record[source]¶

process_before_flush(batch: List[Record]) → List[Record][source]¶

process_before_poll()[source]¶

class papfa.middlewares.consumer.MessageKey(topic: str, group_id: str)[source]¶

Bases: object

group_id: str¶

topic: str¶

papfa.middlewares.producer module¶

class papfa.middlewares.producer.ProducerMiddleware[source]¶

Bases: ABC

process_after_produce(message: dict)[source]¶

process_before_produce(message: dict) → dict[source]¶

Module contents¶