Skip to content

KafkaPrometheusMiddleware

faststream.confluent.prometheus.middleware.KafkaPrometheusMiddleware #

KafkaPrometheusMiddleware(
    *,
    registry: CollectorRegistry,
    app_name: str = EMPTY,
    metrics_prefix: str = "faststream",
    received_messages_size_buckets: Sequence[float]
    | None = None,
    custom_labels: dict[str, str | Callable[[Any], str]]
    | None = None,
)

Bases: PrometheusMiddleware[Message | Sequence[Message], KafkaPublishCommand]

Source code in faststream/confluent/prometheus/middleware.py 
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
def __init__(
    self,
    *,
    registry: "CollectorRegistry",
    app_name: str = EMPTY,
    metrics_prefix: str = "faststream",
    received_messages_size_buckets: Sequence[float] | None = None,
    custom_labels: dict[str, str | Callable[[Any], str]] | None = None,
) -> None:
    super().__init__(
        settings_provider_factory=settings_provider_factory,  # type: ignore[arg-type]
        registry=registry,
        app_name=app_name,
        metrics_prefix=metrics_prefix,
        received_messages_size_buckets=received_messages_size_buckets,
        custom_labels=custom_labels,
    )