kafka compress - Githubissues

ego-component / ekafka

ekafka,kafka,ego

MIT License

7 stars 5 forks source link

kafka compress #12

Closed qingbozhang closed 1 year ago

qingbozhang commented 1 year ago

EnableCompress 是否开启压缩
CompressLimit 触发压缩大小阈值默认10KB
CompressType 默认 gzip 用户可以调用Register方法注册自定义压缩方式
写入时使用 compressClientInterceptor，header中增加 Content-Encoding
读取时候使用 compressServerInterceptor，解压之后移除header中的 Content-Encoding