Set WithDecoderConcurrency to 0 so GOMAXPROCS is used

IBM · Dec 15, 2022 · 8575d6f · 8575d6f
1 parent 0e25670
commit 8575d6f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/zstd.go b/zstd.go
@@ -1,7 +1,6 @@
 package sarama
 
 import (
-	"runtime"
 	"sync"
 
 	"github.com/klauspost/compress/zstd"
@@ -58,7 +57,7 @@ func getDecoder(params ZstdDecoderParams) *zstd.Decoder {
 	}
 	// It's possible to race and create multiple new readers.
 	// Only one will survive GC after use.
-	zstdDec, _ := zstd.NewReader(nil, zstd.WithDecoderConcurrency(runtime.NumCPU()))
+	zstdDec, _ := zstd.NewReader(nil, zstd.WithDecoderConcurrency(0))
 	zstdDecMap.Store(params, zstdDec)
 	return zstdDec
 }