rptest: Fix timequery test

The test uses constant timestamp to generate records and query them. But
the timestamp is too old so retention policy starts to remove data while
the test is running. This commit makes the test use proper base
timestamp.

Signed-off-by: Evgeny Lazin <[email protected]>

Author: Lazin

tests/rptest/tests/timequery_test.py

@@ -108,7 +108,7 @@ def _create_and_produce(
     def _test_timequery(self, cluster, cloud_storage: bool, batch_cache: bool):
         total_segments = 12
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
         local_retention = self.log_segment_size * 4
         kcat = KafkaCat(cluster)
@@ -270,7 +270,7 @@ def _test_timequery_below_start_offset(self, cluster):
         total_segments = 3
         local_retain_segments = 1
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
 
         topic, timestamps = self._create_and_produce(
@@ -416,7 +416,7 @@ def test_timequery_with_local_gc(self):
         self.set_up_cluster(cloud_storage=True, batch_cache=False, spillover=False)
         local_retention = self.log_segment_size * 4
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
 
         topic, timestamps = self._create_and_produce(
@@ -494,7 +494,7 @@ def test_timequery_with_trim_prefix(self, cloud_storage: bool, spillover: bool):
         )
         total_segments = 12
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
         local_retention = self.log_segment_size * 4
         topic, timestamps = self._create_and_produce(
@@ -554,7 +554,7 @@ def test_timequery_with_spillover_gc_delayed(self):
         self.set_up_cluster(cloud_storage=True, batch_cache=False, spillover=True)
         total_segments = 16
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
         local_retention = self.log_segment_size * 4
         topic_retention = self.log_segment_size * 8
@@ -655,7 +655,7 @@ def test_timequery_empty_local_log(self):
 
         total_segments = 3
         record_size = 1024
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         msg_count = (self.log_segment_size * total_segments) // record_size
         local_retention = 1  # Any value works for this test.
         topic, timestamps = self._create_and_produce(
@@ -868,7 +868,7 @@ def query_timestamp(self, ts, kcat_src, kcat_rr):
 
     @ducktape_cluster(num_nodes=7)
     def test_timequery(self):
-        base_ts = 1664453149000
+        base_ts = int(time.time()) * 1000
         num_messages = 1000
         self.setup_clusters(base_ts, num_messages, 3)