文件名称：kafka_protocol:Kafka协议Erlang库
文件大小：132KB
文件格式：ZIP
更新时间：2024-05-28 10:56:18
klarna-featured 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
【文件预览】：
kafka_protocol-master
----.gitignore(125B)
----Makefile(1KB)
----src()
--------kpro_req_lib.erl(20KB)
--------kpro_prelude_schema.erl(2KB)
--------kpro_sasl.erl(5KB)
--------kpro.erl(21KB)
--------kpro_api_vsn.erl(2KB)
--------kpro_schema.erl(70KB)
--------kpro_brokers.erl(12KB)
--------kpro_connection.erl(21KB)
--------kpro_auth_backend.erl(1KB)
--------kpro_lib.erl(14KB)
--------kafka_protocol.app.src(664B)
--------kpro_txn_lib.erl(6KB)
--------kpro_batch_v01.erl(8KB)
--------kpro_consumer_group.erl(7KB)
--------kpro_sent_reqs.erl(4KB)
--------kpro_compress.erl(4KB)
--------kpro_app.erl(323B)
--------kpro_batch.erl(13KB)
--------kpro_rsp_lib.erl(5KB)
--------kpro_scram.erl(5KB)
--------kpro_varint.erl(2KB)
----.travis.yml(948B)
----changelog.md(8KB)
----priv()
--------.gitignore(13B)
--------error-codes.eterm(10KB)
--------kpro_scanner.xrl(763B)
--------kpro_gen.escript(9KB)
--------kafka_protocol_bnf()
--------api-keys.eterm(996B)
--------ssl()
--------kpro_parser.yrl(1KB)
--------kafka.bnf(219KB)
----LICENSE(10KB)
----rebar.config(636B)
----.github()
--------workflows()
----scripts()
--------run-eunit.sh(270B)
--------setup-testbed.sh(2KB)
----README.md(4KB)
----include()
--------kpro_public.hrl(1KB)
--------kpro.hrl(2KB)
--------kpro_error_codes.hrl(6KB)
--------kpro_private.hrl(4KB)
----NOTICE(175B)
----rebar.config.script(991B)
----test()
--------kpro_txn_tests.erl(11KB)
--------kpro_lib_tests.erl(2KB)
--------kpro_batch_tests.erl(3KB)
--------kpro_topic_mngr_tests.erl(8KB)
--------kpro_produce_req_encode_benchmark_tests.erl(2KB)
--------kpro_produce_tests.erl(5KB)
--------kpro_fetch_tests.erl(10KB)
--------kpro_group_tests.erl(9KB)
--------kpro_list_offsets_tests.erl(3KB)
--------kpro_schema_tests.erl(1KB)
--------kpro_connection_tests.erl(3KB)
--------kpro_varint_tests.erl(1KB)
--------kpro_test_lib.erl(9KB)