diff --git a/requirements.txt b/requirements.txt
index 646e35e..284faa4 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,4 +1,4 @@
-paho-mqtt~=1.6.1
+paho-mqtt>=2.0.0
 pymodbus==3.0.2
 watchdog~=2.1.9
 pyModbusTCP
diff --git a/tedge_modbus/reader/reader.py b/tedge_modbus/reader/reader.py
index df1e9b4..963d5b2 100644
--- a/tedge_modbus/reader/reader.py
+++ b/tedge_modbus/reader/reader.py
@@ -374,7 +374,9 @@ def connect_to_tedge(self):
                 broker = self.base_config["thinedge"]["mqtthost"]
                 port = self.base_config["thinedge"]["mqttport"]
                 client_id = "modbus-client"
-                client = mqtt_client.Client(client_id)
+                client = mqtt_client.Client(
+                    mqtt_client.CallbackAPIVersion.VERSION1, client_id
+                )
                 client.connect(broker, port)
                 self.logger.debug("Connected to MQTTT broker at %s:%d", broker, port)
                 return client