Skip to content

make_logging_listener

faststream.kafka.helpers.make_logging_listener #

make_logging_listener(
    *,
    consumer: AIOKafkaConsumer,
    logger: Optional[LoggerProto],
    log_extra: dict[str, Any],
    listener: Optional[ConsumerRebalanceListener],
) -> Optional[ConsumerRebalanceListener]
Source code in faststream/kafka/helpers/rebalance_listener.py 
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
def make_logging_listener(
    *,
    consumer: "AIOKafkaConsumer",
    logger: Optional["LoggerProto"],
    log_extra: dict[str, Any],
    listener: Optional["ConsumerRebalanceListener"],
) -> Optional["ConsumerRebalanceListener"]:
    if logger is None:
        return listener

    logging_listener = _LoggingListener(
        consumer=consumer,
        logger=logger,
        log_extra=log_extra,
    )
    if listener is None:
        return logging_listener

    return _LoggingListenerFacade(
        logging_listener=logging_listener,
        listener=listener,
    )