diff --git a/src/connector/src/source/mqtt/enumerator/mod.rs b/src/connector/src/source/mqtt/enumerator/mod.rs
index 58872edf4b9c5..64b37d62cb495 100644
--- a/src/connector/src/source/mqtt/enumerator/mod.rs
+++ b/src/connector/src/source/mqtt/enumerator/mod.rs
@@ -114,8 +114,7 @@ impl SplitEnumerator for MqttSplitEnumerator {
         let topics_clone = topics.clone();
         tokio::spawn(async move {
             while !stopped_clone.load(std::sync::atomic::Ordering::Relaxed) {
-                let a = eventloop.poll().await;
-                match a {
+                match eventloop.poll().await {
                     Ok(Event::Outgoing(Outgoing::Subscribe(_))) => {
                         connected_state_clone.set_is_connected(true);
                     }