diff --git a/internal/agent/agent.go b/internal/agent/agent.go
index 0d24640..3602310 100644
--- a/internal/agent/agent.go
+++ b/internal/agent/agent.go
@@ -202,7 +202,10 @@ func newServer(c AgentConfig) server {
 		c.Logger.Fatal(err.Error())
 	}
 
-	decoder, err := zstd.NewReader(nil)
+	decoder, err := zstd.NewReader(
+		nil,
+		zstd.WithDecoderConcurrency(1),
+	)
 	if err != nil {
 		c.Logger.Fatal(err.Error())
 	}
diff --git a/internal/hub/server.go b/internal/hub/server.go
index cc0ac15..2ccf055 100644
--- a/internal/hub/server.go
+++ b/internal/hub/server.go
@@ -137,7 +137,10 @@ func newClient(c HubConfig, payloadCh chan []byte) *autopaho.ConnectionManager {
 }
 
 func newServer(c HubConfig) server {
-	decoder, err := zstd.NewReader(nil)
+	decoder, err := zstd.NewReader(
+		nil,
+		zstd.WithDecoderConcurrency(1),
+	)
 	if err != nil {
 		c.Logger.Fatal(err.Error())
 	}