diff --git a/src/mqtt/MQTT.cpp b/src/mqtt/MQTT.cpp
index df2d9b093..6637c324a 100644
--- a/src/mqtt/MQTT.cpp
+++ b/src/mqtt/MQTT.cpp
@@ -165,6 +165,7 @@ void MQTT::reconnect()
             serverAddr = server.c_str();
         }
         pubSub.setServer(serverAddr, serverPort);
+        pubSub.setBufferSize(512);
 
         DEBUG_MSG("Connecting to MQTT server %s, port: %d, username: %s, password: %s\n", serverAddr, serverPort, mqttUsername, mqttPassword);
         auto myStatus = (statusTopic + owner.id);