diff --git a/insteon_mqtt/cmd_line/util.py b/insteon_mqtt/cmd_line/util.py
index 4af6aa05..3e05cb61 100644
--- a/insteon_mqtt/cmd_line/util.py
+++ b/insteon_mqtt/cmd_line/util.py
@@ -74,7 +74,7 @@ def send(config, topic, payload, quiet=False):
         "quiet" : int(quiet),
         }
 
-    client = mqtt.Client(userdata=session)
+    client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, userdata=session)
 
     # Add user/password if the config file has them set.
     if config["mqtt"].get("username", None):
diff --git a/insteon_mqtt/network/Mqtt.py b/insteon_mqtt/network/Mqtt.py
index 90157fc7..0490d632 100644
--- a/insteon_mqtt/network/Mqtt.py
+++ b/insteon_mqtt/network/Mqtt.py
@@ -108,7 +108,8 @@ def setup_client(self):
         client_args = {'client_id': self.id, 'clean_session': False}
 
         if not hasattr(self, 'client'):
-            self.client = paho.Client(**client_args)
+            self.client = paho.Client(paho.CallbackAPIVersion.VERSION1,
+                                      **client_args)
         else:
             self.client.reinitialise(**client_args)
         self.client.on_connect = self._on_connect
diff --git a/requirements.txt b/requirements.txt
index 5493d732..38c80f78 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,4 +1,4 @@
-paho-mqtt>=1.3
+paho-mqtt>=2.0
 pyserial>=3.2
 pyyaml>=3
 Jinja2>=2.1