Skip to content

telemetry_attributes_provider_factory

faststream.kafka.opentelemetry.provider.telemetry_attributes_provider_factory #

telemetry_attributes_provider_factory(msg)
Source code in faststream/kafka/opentelemetry/provider.py 
106
107
108
109
110
111
112
113
114
115
def telemetry_attributes_provider_factory(
    msg: Union["ConsumerRecord", Sequence["ConsumerRecord"], None],
) -> Union[
    KafkaTelemetrySettingsProvider,
    BatchKafkaTelemetrySettingsProvider,
]:
    if isinstance(msg, Sequence):
        return BatchKafkaTelemetrySettingsProvider()
    else:
        return KafkaTelemetrySettingsProvider()