BaseKafkaMetricsSettingsProvider
faststream.kafka.prometheus.provider.BaseKafkaMetricsSettingsProvider #
Bases: MetricsSettingsProvider[MsgType]
faststream.kafka.prometheus.provider.BaseKafkaMetricsSettingsProvider # Bases: MetricsSettingsProvider[MsgType]
faststream/kafka/prometheus/provider.py
get_consume_attrs_from_message #