diff --git a/src/connector/src/sink/mqtt.rs b/src/connector/src/sink/mqtt.rs
index d9dfdbe03b21b..9e86b5ec97e2a 100644
--- a/src/connector/src/sink/mqtt.rs
+++ b/src/connector/src/sink/mqtt.rs
@@ -288,7 +288,7 @@ impl MqttSinkWriter {
                         }
                         err => {
                             tracing::error!("Failed to poll mqtt eventloop: {}", err.as_report());
-                            std::thread::sleep(std::time::Duration::from_secs(1));
+                            tokio::time::sleep(std::time::Duration::from_secs(1)).await;
                         }
                     },
                 }