diff --git a/ttn-vegapulsair-exporter.py b/ttn-vegapulsair-exporter.py
index d44ac6d..702921c 100644
--- a/ttn-vegapulsair-exporter.py
+++ b/ttn-vegapulsair-exporter.py
@@ -152,7 +152,7 @@ def poll_mqtt(mqttc):
 def main():
     print("starting ...")
 
-    mqttc = mqtt.Client()
+    mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1)
     mqttc.on_connect = on_connect
     mqttc.on_subscribe = on_subscribe
     mqttc.on_message = on_message