Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 16 additions & 10 deletions sentry_streams/sentry_streams/rust_streams.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -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],
Expand All @@ -40,16 +33,29 @@ 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: ...
Comment thread
cursor[bot] marked this conversation as resolved.

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__(
Expand Down
Loading