diff --git a/connector/examples/combined_example_consumer.rs b/connector/examples/combined_example_consumer.rs
index ef390c7..6697e7f 100644
--- a/connector/examples/combined_example_consumer.rs
+++ b/connector/examples/combined_example_consumer.rs
@@ -95,8 +95,8 @@ async fn main() -> anyhow::Result<()> {
     let filter_config = filter_config1;
 
     grpc_plugin_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
         metrics_tx.clone(),
diff --git a/connector/examples/geyser_example_consumer.rs b/connector/examples/geyser_example_consumer.rs
index ef390c7..6697e7f 100644
--- a/connector/examples/geyser_example_consumer.rs
+++ b/connector/examples/geyser_example_consumer.rs
@@ -95,8 +95,8 @@ async fn main() -> anyhow::Result<()> {
     let filter_config = filter_config1;
 
     grpc_plugin_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
         metrics_tx.clone(),
diff --git a/connector/examples/websocket_example_consumer.rs b/connector/examples/websocket_example_consumer.rs
index cde15b5..e466952 100644
--- a/connector/examples/websocket_example_consumer.rs
+++ b/connector/examples/websocket_example_consumer.rs
@@ -77,8 +77,8 @@ async fn main() -> anyhow::Result<()> {
     });
 
     websocket_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
     )