From 49a618dfe2921ab451002e926e029d3c9fe1c0ae Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 25 Jan 2022 14:20:12 +0000 Subject: [PATCH] Increase maximum message size to 16MB (#2109) --- setup/jetstream/nats.go | 1 + 1 file changed, 1 insertion(+) 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)