Merge pull request #377 from FundingCircle/mc-fix-seek-to-timestamp

Retrieve end offsets before searching for offsets for timestamp
FundingCircle · Aug 16, 2024 · 6448a8e · 6448a8e
2 parents bc35601 + e1cc7fb
commit 6448a8e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/jackdaw/client.clj b/src/jackdaw/client.clj
@@ -281,10 +281,10 @@
   [^Consumer consumer timestamp topics]
   (let [topic-partitions (->> (mapcat #(partitions-for consumer %) topics)
                               (map #(select-keys % [:topic-name :partition])))
+        end-offsets      (end-offsets consumer topic-partitions)
         ts-offsets       (offsets-for-times consumer
                                          (zipmap topic-partitions
                                                  (repeat (count topic-partitions) timestamp)))
-        end-offsets      (end-offsets consumer topic-partitions)
         offsets          (reduce-kv (fn [m k v]
                                       (assoc m k {:ts-offset v
                                                   :end-offset (get end-offsets k)}))