aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNeil Alexander <neilalexander@users.noreply.github.com>2022-01-25 14:20:12 +0000
committerGitHub <noreply@github.com>2022-01-25 14:20:12 +0000
commit49a618dfe2921ab451002e926e029d3c9fe1c0ae (patch)
treed697f54d4969516d9e5be69516f4b1ca7533cf12
parenta5c5de860b5f87aba7dc720f7a4f3af94a75d2a6 (diff)
Increase maximum message size to 16MB (#2109)
-rw-r--r--setup/jetstream/nats.go1
1 files changed, 1 insertions, 0 deletions
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)