diff --git a/src/MQTTLibrary/MQTTKeywords.py b/src/MQTTLibrary/MQTTKeywords.py
index 63934b5..9b2ec3a 100644
--- a/src/MQTTLibrary/MQTTKeywords.py
+++ b/src/MQTTLibrary/MQTTKeywords.py
@@ -68,7 +68,9 @@ def connect(self, broker, port=1883, client_id="", clean_session=True):
         logger.info('Connecting to %s at port %s' % (broker, port))
         self._connected = False
         self._unexpected_disconnect = False
-        self._mqttc = mqtt.Client(client_id, clean_session)
+        self._mqttc = mqtt.Client(
+            mqtt.CallbackAPIVersion.VERSION1, client_id, clean_session
+        )
 
         # set callbacks
         self._mqttc.on_connect = self._on_connect