diff --git a/internal/pub/jetstream.go b/internal/pub/jetstream.go index 55924fa..972df43 100644 --- a/internal/pub/jetstream.go +++ b/internal/pub/jetstream.go @@ -49,7 +49,7 @@ func NewJetStreamPub(o JetStreamOpts) (Pub, error) { Subjects: streamSubjects, MaxAge: o.PersistDuration, Storage: jetstream.FileStorage, - Duplicates: time.Minute, + Duplicates: time.Minute * 20, }) return &jetStreamPub{