From 9a0b0f1e8e70818428b5695fa6bbcdcad6c4e452 Mon Sep 17 00:00:00 2001 From: victoria-yining-huang Date: Thu, 16 Apr 2026 12:57:33 -0400 Subject: [PATCH 1/2] add property decorators --- .../sentry_streams/rust_streams.pyi | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/sentry_streams/sentry_streams/rust_streams.pyi b/sentry_streams/sentry_streams/rust_streams.pyi index 4aabf22b..3c2d3bc3 100644 --- a/sentry_streams/sentry_streams/rust_streams.pyi +++ b/sentry_streams/sentry_streams/rust_streams.pyi @@ -24,13 +24,6 @@ class OffsetResetConfig: def __init__(self, auto_offset_reset: InitialOffset, strict_offset_reset: bool) -> None: ... class PyKafkaConsumerConfig: - bootstrap_servers: Sequence[str] - group_id: str - auto_offset_reset: InitialOffset - strict_offset_reset: bool - max_poll_interval_ms: int - override_params: Mapping[str, str] | None - def __init__( self, bootstrap_servers: Sequence[str], @@ -40,6 +33,18 @@ class PyKafkaConsumerConfig: max_poll_interval_ms: int, override_params: Mapping[str, str] | None = None, ) -> None: ... + @property + def bootstrap_servers(self) -> Sequence[str]: ... + @property + def group_id(self) -> str: ... + @property + def auto_offset_reset(self) -> InitialOffset: ... + @property + def strict_offset_reset(self) -> bool: ... + @property + def max_poll_interval_ms(self) -> int: ... + @property + def override_params(self) -> Mapping[str, str] | None: ... class PyKafkaProducerConfig: bootstrap_servers: Sequence[str] From 59a9fd680613d74f161111633d5962448205afba Mon Sep 17 00:00:00 2001 From: victoria-yining-huang Date: Thu, 16 Apr 2026 13:01:11 -0400 Subject: [PATCH 2/2] also producer config --- sentry_streams/sentry_streams/rust_streams.pyi | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/sentry_streams/sentry_streams/rust_streams.pyi b/sentry_streams/sentry_streams/rust_streams.pyi index 3c2d3bc3..ab619604 100644 --- a/sentry_streams/sentry_streams/rust_streams.pyi +++ b/sentry_streams/sentry_streams/rust_streams.pyi @@ -47,14 +47,15 @@ class PyKafkaConsumerConfig: def override_params(self) -> Mapping[str, str] | None: ... class PyKafkaProducerConfig: - bootstrap_servers: Sequence[str] - override_params: Mapping[str, str] | None - def __init__( self, bootstrap_servers: Sequence[str], override_params: Mapping[str, str] | None = None, ) -> None: ... + @property + def bootstrap_servers(self) -> Sequence[str]: ... + @property + def override_params(self) -> Mapping[str, str] | None: ... class PyMetricConfig: def __init__(