diff --git a/custom_components/bemfa/mqtt.py b/custom_components/bemfa/mqtt.py
index 7544707..e75f650 100644
--- a/custom_components/bemfa/mqtt.py
+++ b/custom_components/bemfa/mqtt.py
@@ -54,7 +54,7 @@ def create_sync(self, sync: Sync):
             TOPIC_PUBLISH.format(topic=sync.topic),
             sync.generate_msg(),
         )
-        self._mqttc.subscribe(sync.topic, 2)
+        self._mqttc.subscribe(sync.topic, 1)
 
     def modify_sync(self, sync: Sync):
         """Modify a sync."""
@@ -87,7 +87,7 @@ def connect(self) -> None:
         )
 
         # Listen for heartbeat packages
-        self._mqttc.subscribe(TOPIC_PING, 2)
+        self._mqttc.subscribe(TOPIC_PING, 1)
 
     def _ping(self):
         async def _receive_job():