removes unused code

mkroli · May 17, 2024 · 7f19fe2 · 7f19fe2
1 parent 18eaa6e
commit 7f19fe2
Showing 1 changed file with 0 additions and 11 deletions.
diff --git a/src/kafka_stream_ext.rs b/src/kafka_stream_ext.rs
@@ -89,17 +89,6 @@ impl<'a, S: ?Sized, E> KafkaStreamExt<'a> for S where
 }
 
 pub trait KafkaStreamExt<'a>: Stream {
-    fn store_offsets<C>(self, consumer: C) -> StoreOffsets<'a, Self>
-    where
-        Self: Sized,
-        C: Into<&'a StreamConsumer>,
-    {
-        StoreOffsets {
-            consumer: consumer.into(),
-            stream: self,
-        }
-    }
-
     fn try_store_offsets<C>(self, consumer: C) -> TryStoreOffsets<'a, Self>
     where
         Self: Sized,