diff --git a/src/topology/running.rs b/src/topology/running.rs
index 0cd0cd646bdb6..9a5c302185912 100644
--- a/src/topology/running.rs
+++ b/src/topology/running.rs
@@ -196,7 +196,7 @@ impl RunningTopology {
         // Aggregate future that ends once anything detects that all tasks have shutdown.
         let shutdown_complete_future = future::select_all(vec![
             Box::pin(timeout) as future::BoxFuture<'static, Result<(), ()>>,
-            Box::pin(reporter) as future::BoxFuture<'static, ()>,
+            Box::pin(reporter.map(|()| Result::<(), ()>::Ok(()))) as future::BoxFuture<'static, Result<(), ()>>,
             Box::pin(success) as future::BoxFuture<'static, Result<(), ()>>,
         ]);