The low watermark is not updated in the cache

ermakov-oleg · Apr 27, 2024 · e7c36fe · e7c36fe
1 parent b5616b6
commit e7c36fe
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/kafka_earliest_timestamp_exporter/_main.py b/src/kafka_earliest_timestamp_exporter/_main.py
@@ -45,7 +45,7 @@ def _once(consumer: Consumer, offset_state: '_State', debug: bool) -> None:
         topic_partitions = []
         topic_offsets = {}
         for partition in metadata.partitions:
-            low, high = consumer.get_watermark_offsets(TopicPartition(topic, partition), cached=True)
+            low, high = consumer.get_watermark_offsets(TopicPartition(topic, partition))
             # Skip empty partitions
             if low == high:
                 continue

diff --git a/src/kafka_earliest_timestamp_exporter/cli.py b/src/kafka_earliest_timestamp_exporter/cli.py
@@ -11,7 +11,7 @@
 @click.option('--config', type=click.Path(exists=True, dir_okay=False, path_type=Path), required=True)
 @click.option('--host', type=str, default='127.0.0.1')
 @click.option('--port', type=int, default=7900)
-@click.option('--interval', type=int, default=60)
+@click.option('--interval', type=int, default=60 * 5)
 @click.option('--state-persistence', is_flag=True)
 @click.option('--debug', is_flag=True)
 def cli(config: Path, host: str, port: int, interval: int, state_persistence: bool, debug: bool) -> None: