diff --git a/src/lavinmq/clustering/client.cr b/src/lavinmq/clustering/client.cr
index b7e13ef02b..95b5e90b58 100644
--- a/src/lavinmq/clustering/client.cr
+++ b/src/lavinmq/clustering/client.cr
@@ -254,6 +254,7 @@ module LavinMQ
       private def log_streamed_bytes_loop
         loop do
           sleep 30.seconds
+          break if @closed
           Log.info { "Total streamed bytes: #{@streamed_bytes}" }
         end
       end