diff --git a/consumer/src/main.rs b/consumer/src/main.rs
index eff3984b..f574f2cc 100644
--- a/consumer/src/main.rs
+++ b/consumer/src/main.rs
@@ -132,14 +132,13 @@ async fn main() -> eyre::Result<()> {
         tracker.spawn(index_transport(index_client, idxc_rx));
     }
 
-    let tc = tracker.clone();
-    tracker.spawn(async move {
+    tokio::spawn(async move {
         let _ = ctrl_c().await;
         tracing::info!("stopping consumer");
         stop_tx.send(true).unwrap();
-        tc.close();
     });
 
+    tracker.close();
     tracker.wait().await;
 
     Ok(())