diff --git a/src/mqtt_helper.py b/src/mqtt_helper.py
index e726ff8..9b1ed93 100644
--- a/src/mqtt_helper.py
+++ b/src/mqtt_helper.py
@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+import logging
 import paho.mqtt.client as mqtt
 import config
 
@@ -59,6 +60,7 @@ class MQTT:
         """
         self.client = mqtt.Client(client_id=self.client_id, clean_session=True, userdata=None, protocol=mqtt.MQTTv311,
                                   transport="tcp")
+        self.port = int(self.port)
         self.client.connect(host=self.host, port=self.port, keepalive=60)
 
     def publish(self, message: str, subtopic: str = "") -> None: