feat: use DateTime<Utc> when query timestamp offset for end user

Author: fMeow

Cargo.toml

@@ -74,7 +74,6 @@ compression-gzip = ["flate2"]
 compression-lz4 = ["lz4"]
 compression-snappy = ["snap"]
 compression-zstd = ["zstd"]
-timestamp-query = []
 
 transport-socks5 = ["async-socks5"]
 transport-tls = ["rustls", "tokio-rustls"]

src/client/partition.rs

@@ -23,7 +23,7 @@ use crate::{
     throttle::maybe_throttle,
     validation::ExactlyOne,
 };
-use chrono::{LocalResult, TimeZone, Utc};
+use chrono::{DateTime, LocalResult, TimeZone, Utc};
 use std::{
     ops::{ControlFlow, Deref, Range},
     sync::Arc,
@@ -98,9 +98,8 @@ pub enum OffsetAt {
     /// The latest existing record.
     Latest,
 
-    #[cfg(feature = "timestamp-query")]
     /// Timestamp
-    Timestamp(i64),
+    Timestamp(DateTime<Utc>),
 }
 
 #[derive(Debug)]
@@ -906,8 +905,7 @@ fn build_list_offsets_request(partition: i32, topic: &str, at: OffsetAt) -> List
     let timestamp = match at {
         OffsetAt::Earliest => -2,
         OffsetAt::Latest => -1,
-        #[cfg(feature = "timestamp-query")]
-        OffsetAt::Timestamp(ts) => ts,
+        OffsetAt::Timestamp(ts) => ts.timestamp_millis(),
     };
 
     ListOffsetsRequest {