Skip to content

Commit

Permalink
Fix YAML maxBytes not being set on Stream (#60)
Browse files Browse the repository at this point in the history
Currently, we accept maxBytes in the Stream YAML. However, we're not
actually passing this value to the client. This leads to a Stream being
created without maxBytes set.

This change passes maxBytes to the client so Streams get correctly
created.
  • Loading branch information
variadico authored Jan 13, 2022
1 parent bb5fd8b commit d4e6b50
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions controllers/jetstream/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -255,6 +255,7 @@ func createStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e
jsm.Replicas(spec.Replicas),
jsm.DuplicateWindow(duplicates),
jsm.MaxAge(maxAge),
jsm.MaxBytes(int64(spec.MaxBytes)),
}

switch spec.Retention {
Expand Down

0 comments on commit d4e6b50

Please sign in to comment.