Skip to content

settings_provider_factory

faststream.kafka.prometheus.provider.settings_provider_factory #

settings_provider_factory(
    msg: Union[
        ConsumerRecord, Sequence[ConsumerRecord], None
    ],
) -> (
    KafkaMetricsSettingsProvider
    | BatchKafkaMetricsSettingsProvider
)
Source code in faststream/kafka/prometheus/provider.py 
63
64
65
66
67
68
def settings_provider_factory(
    msg: Union["ConsumerRecord", Sequence["ConsumerRecord"], None],
) -> KafkaMetricsSettingsProvider | BatchKafkaMetricsSettingsProvider:
    if isinstance(msg, Sequence):
        return BatchKafkaMetricsSettingsProvider()
    return KafkaMetricsSettingsProvider()