kafka_protocol:Kafka协议Erlang库

用于Erlang / Elixir的Kafka协议库 该库提供： 基本的Kafka连接管理API Kafka协议线路格式编码/解码功能 Kafka RPC原语 实用程序功能可帮助构建请求和解析响应 有关完整的kafka客户端实现，请参见 。 压缩支持 从4.0开始，此库不再包含和作为钢筋依赖项。 但是， kafka_protocol仍然默认使用snappyer和lz4b_frame进行压缩和解压缩。 提供压缩模块替代 用户可以使用已实现以下API的模块覆盖默认压缩库： -callback compress(iodata()) -> iodata(). -callback decompress(binary()) -> iodata(). 有两种方法可以将这种动态依赖项注入kakfa_protocol ： 设置应用环境 例如{provide_compression, [{lz4, my