diff --git a/codec/compression_codec.go b/codec/compression_codec.go
index 0a46339..44dc606 100644
--- a/codec/compression_codec.go
+++ b/codec/compression_codec.go
@@ -48,6 +48,12 @@ func (_ *GZipCodec) Decode(message []byte) ([]byte, error) {
 
 var gZipCodec = &GZipCodec{}
 
+func NewCompressionCodecSelector(threshold int) CodecSelector {
+	return &compressionCodecSelector{
+		threshold: threshold,
+	}
+}
+
 type compressionCodecSelector struct {
 	threshold int
 }