Skip to content

telemetry_attributes_provider_factory

faststream.kafka.opentelemetry.provider.telemetry_attributes_provider_factory #

telemetry_attributes_provider_factory(
    msg: Union[
        ConsumerRecord, Sequence[ConsumerRecord], None
    ],
) -> (
    KafkaTelemetrySettingsProvider
    | BatchKafkaTelemetrySettingsProvider
)
Source code in faststream/kafka/opentelemetry/provider.py 
116
117
118
119
120
121
def telemetry_attributes_provider_factory(
    msg: Union["ConsumerRecord", Sequence["ConsumerRecord"], None],
) -> KafkaTelemetrySettingsProvider | BatchKafkaTelemetrySettingsProvider:
    if isinstance(msg, Sequence):
        return BatchKafkaTelemetrySettingsProvider()
    return KafkaTelemetrySettingsProvider()