diff --git a/Cargo.lock b/Cargo.lock
index 8e3d48a0..abe15dbe 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4616,9 +4616,9 @@ dependencies = [
 
 [[package]]
 name = "rdkafka"
-version = "0.33.2"
+version = "0.34.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "da18026aad1c24033da3da726200de7e911e75c2e2cc2f77ffb9b4502720faae"
+checksum = "053adfa02fab06e86c01d586cc68aa47ee0ff4489a59469081dc12cbcde578bf"
 dependencies = [
  "futures-channel",
  "futures-util",
diff --git a/web3_proxy/Cargo.toml b/web3_proxy/Cargo.toml
index b61078e4..0ed4ba27 100644
--- a/web3_proxy/Cargo.toml
+++ b/web3_proxy/Cargo.toml
@@ -73,7 +73,7 @@ once_cell = { version = "1.18.0" }
 ordered-float = {version = "3.9.1" }
 pagerduty-rs = { version = "0.1.6", default-features = false, features = ["async", "rustls", "sync"] }
 parking_lot = { version = "0.12.1", features = ["arc_lock", "nightly"] }
-rdkafka = { version = "0.33.2", features = ["tracing"] }
+rdkafka = { version = "0.34.0", features = ["tracing"] }
 regex = "1.9.4"
 reqwest = { version = "0.11.20", default-features = false, features = ["deflate", "gzip", "json", "tokio-rustls"] }
 rmp-serde = "1.1.2"
diff --git a/web3_proxy/src/stats/mod.rs b/web3_proxy/src/stats/mod.rs
index 7830711e..5217ea6d 100644
--- a/web3_proxy/src/stats/mod.rs
+++ b/web3_proxy/src/stats/mod.rs
@@ -421,7 +421,8 @@ impl BufferedRpcQueryStats {
 
                         let now = Utc::now();
                         let valid_until =
-                            DateTime::<Utc>::from_utc(referral_start_date, Utc) + Months::new(12);
+                            DateTime::<Utc>::from_naive_utc_and_offset(referral_start_date, Utc)
+                                + Months::new(12);
 
                         // If the referrer ever had premium, provide credits to them
                         // Also only works if the referrer referred the person less than 1 year ago