Skip to content

Commit

Permalink
Bump window
Browse files Browse the repository at this point in the history
  • Loading branch information
ericvolp12 committed Sep 23, 2024
1 parent e90e669 commit 5f96e83
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/consumer/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ func NewConsumer(
return nil, fmt.Errorf("failed to create clock: %w", err)
}

// Create a zstd encoder using the dictionary and a window size of 8KB
encoder, err := zstd.NewWriter(nil, zstd.WithEncoderDict(models.ZSTDDictionary), zstd.WithWindowSize(2<<12), zstd.WithEncoderConcurrency(1))
// Create a zstd encoder using the dictionary and a window size of 128KiB
encoder, err := zstd.NewWriter(nil, zstd.WithEncoderDict(models.ZSTDDictionary), zstd.WithWindowSize(1<<17), zstd.WithEncoderConcurrency(1))
if err != nil {
return nil, fmt.Errorf("failed to create zstd encoder: %w", err)
}
Expand Down

0 comments on commit 5f96e83

Please sign in to comment.