diff --git a/src/connect.rs b/src/connect.rs
index 654b975..7992bc6 100644
--- a/src/connect.rs
+++ b/src/connect.rs
@@ -154,6 +154,9 @@ where
 
             if read_size == 0 {
                 warn!("Received empty response, chunk: {}.", chunk);
+                if let Err(err) = self.reconnect() {
+                    warn!("Failed to reconnect: {:?}.", err);
+                }
                 Err(Error::Transient(MyError::NoAckResponseError))
             } else {
                 let reply =