diff --git a/quixstreams/app.py b/quixstreams/app.py index e6ae0cdaf..8f8c1f49f 100644 --- a/quixstreams/app.py +++ b/quixstreams/app.py @@ -97,7 +97,7 @@ def __init__( quix_sdk_token: Optional[str] = None, consumer_group: Optional[str] = None, auto_offset_reset: AutoOffsetReset = "latest", - commit_interval: float = 5.0, + commit_interval: float = 2.0, consumer_extra_config: Optional[dict] = None, producer_extra_config: Optional[dict] = None, state_dir: str = "state", diff --git a/quixstreams/state/recovery.py b/quixstreams/state/recovery.py index eaa6c5e10..750bb2407 100644 --- a/quixstreams/state/recovery.py +++ b/quixstreams/state/recovery.py @@ -46,7 +46,7 @@ def __init__( self._recovery_consume_position: Optional[int] = None self._initial_offset: Optional[int] = None - def __str__(self): + def __repr__(self): return f"{self.changelog_name}[{self.partition_num}]" @property