diff --git a/src/lib.rs b/src/lib.rs
index aaa62e9..3c5a4d9 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -151,6 +151,6 @@ pub mod prelude {
     pub use super::operator::window::{CountWindow, ProcessingTimeWindow, SessionWindow};
     #[cfg(feature = "timestamp")]
     pub use super::operator::window::{EventTimeWindow, TransactionWindow};
-    pub use super::{BatchMode, RuntimeConfig, StreamContext};
     pub use super::Replication;
+    pub use super::{BatchMode, RuntimeConfig, StreamContext};
 }
diff --git a/src/operator/source/avro.rs b/src/operator/source/avro.rs
index 1d476db..c6c4ec4 100644
--- a/src/operator/source/avro.rs
+++ b/src/operator/source/avro.rs
@@ -140,7 +140,7 @@ impl<R: MakeReader + Clone> Clone for AvroSource<R> {
         Self {
             reader: None,
             terminated: false,
-            replication: self.replication.clone(),
+            replication: self.replication,
             make_reader: self.make_reader.clone(),
         }
     }
@@ -174,7 +174,9 @@ impl<Op> Stream<Op>
 where
     Op: Operator<Out = Value> + 'static,
 {
-    pub fn from_avro_value<T: for<'de> Deserialize<'de> + Send>(self) -> Stream<impl Operator<Out = T>> {
+    pub fn from_avro_value<T: for<'de> Deserialize<'de> + Send>(
+        self,
+    ) -> Stream<impl Operator<Out = T>> {
         self.map(|v| {
             let de = from_value(&v);
             de.expect("failed to deserialize")