Clippy keeps getting better, and I of course happily comply!

kafkesc · Jan 7, 2024 · 88b6da8 · 88b6da8
1 parent 3e72508
commit 88b6da8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/konsumer_offsets_data/emitter.rs b/src/konsumer_offsets_data/emitter.rs
@@ -57,7 +57,7 @@ impl KonsumerOffsetsDataEmitter {
     ) -> KafkaResult<()> {
         // Fetch topic metadata
         let meta = consumer.fetch_metadata(Some(topic), Duration::from_secs(5))?;
-        let topic_meta = meta.topics().get(0).ok_or(KafkaError::Subscription(format!(
+        let topic_meta = meta.topics().first().ok_or(KafkaError::Subscription(format!(
             "Unable to (self)assign '{}' and seek to earliest offsets",
             topic
         )))?;

diff --git a/src/lag_register/mod.rs b/src/lag_register/mod.rs
@@ -8,7 +8,7 @@ use tokio::sync::mpsc::Receiver;
 use crate::consumer_groups::ConsumerGroups;
 use crate::partition_offsets::PartitionOffsetsRegister;
 
-pub use register::{GroupWithLag, Lag, LagRegister, LagWithOwner};
+pub use register::{Lag, LagRegister};
 
 pub fn init(
     cg_rx: Receiver<ConsumerGroups>,