diff --git a/plugin/mqtt/client.go b/plugin/mqtt/client.go
index c27180b9f..c6fccc7ef 100644
--- a/plugin/mqtt/client.go
+++ b/plugin/mqtt/client.go
@@ -20,7 +20,7 @@ import (
 // Instance is the paho Mqtt client singleton
 var Instance *Client
 
-const parallelInflightLimit int64 = 128
+const parallelInflightLimit int64 = 32
 
 // ClientID created unique mqtt client id
 func ClientID() string {