Change str to repr. Change default commit interval to 2, might lower …

…it more
quixio · Jul 3, 2024 · 8a945e9 · 8a945e9
1 parent 3f16292
commit 8a945e9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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