diff --git a/src/kafka_earliest_timestamp_exporter/_main.py b/src/kafka_earliest_timestamp_exporter/_main.py index 786fb28..02e8498 100644 --- 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 index 60aa820..7c35c2a 100644 --- 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: