diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 6dbbd1f4..5d7937b5 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -33,6 +33,7 @@ func Prepare(cfg *config.JetStream) (nats.JetStreamContext, sarama.Consumer, sar
 			StoreDir:         string(cfg.StoragePath),
 			NoSystemAccount:  true,
 			AllowNewAccounts: false,
+			MaxPayload:       16 * 1024 * 1024,
 		})
 		if err != nil {
 			panic(err)