diff --git a/connectors/cdc-connector/cdc_connector.cpp b/connectors/cdc-connector/cdc_connector.cpp
index e3bc043f2..b27291203 100644
--- a/connectors/cdc-connector/cdc_connector.cpp
+++ b/connectors/cdc-connector/cdc_connector.cpp
@@ -198,6 +198,12 @@ bool Connection::connect(const std::string& table, const std::string& gtid)
 
     try
     {
+        if (m_connected)
+        {
+            m_error = "Already connected";
+            return false;
+        }
+
         m_error.clear();
 
         struct addrinfo *ai = NULL, hint = {};