Skip to content

Commit

Permalink
remove unnecessary conversions
Browse files Browse the repository at this point in the history
  • Loading branch information
asg0451 committed Jul 21, 2024
1 parent d7ea2c3 commit 9347148
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/kgo/compression.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,8 +113,8 @@ out:
case codecGzip:
level := gzip.DefaultCompression
if codec.level != 0 {
if _, err := gzip.NewWriterLevel(nil, int(codec.level)); err != nil {
level = int(codec.level)
if _, err := gzip.NewWriterLevel(nil, codec.level); err != nil {
level = codec.level
}
}
c.gzPool = sync.Pool{New: func() any { c, _ := gzip.NewWriterLevel(nil, level); return c }}
Expand Down

0 comments on commit 9347148

Please sign in to comment.