dekaf: Clean up some compiler warnings

estuary · Jan 15, 2025 · a432255 · a432255
1 parent 4c5aea7
commit a432255
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/crates/dekaf/src/read.rs b/crates/dekaf/src/read.rs
@@ -119,7 +119,7 @@ impl Read {
             Compression, Record, RecordBatchEncoder, RecordEncodeOptions,
         };
 
-        let mut alloc = bumpalo::Bump::new();
+        let alloc = bumpalo::Bump::new();
 
         let mut records: Vec<Record> = Vec::new();
         let mut records_bytes: usize = 0;

diff --git a/crates/dekaf/src/topology.rs b/crates/dekaf/src/topology.rs
@@ -9,7 +9,7 @@ use gazette::{broker, journal, uuid};
 use itertools::Itertools;
 use models::RawValue;
 use proto_flow::flow;
-use std::{iter, time::Duration};
+use std::time::Duration;
 
 impl UserAuth {
     /// Fetch the names of all collections which the current user may read.
@@ -544,7 +544,6 @@ async fn handle_postgrest_response<T: serde::de::DeserializeOwned>(
 // Claims returned by `/authorize/dekaf`
 #[derive(Debug, Clone, serde::Deserialize)]
 pub struct AccessTokenClaims {
-    pub iat: u64,
     pub exp: u64,
 }
 #[tracing::instrument(skip(client, data_plane_signer), err)]