文件名称：brod:适用于ErlangElixir的Apache Kafka客户端库
文件大小：413KB
文件格式：ZIP
更新时间：2024-06-01 15:38:53
client erlang elixir kafka klarna-featured
注意 本产品包括由开发的软件 Brod-适用于Erlang / Elixir的Apache Kafka客户端 Brod是Apache Kafka协议的Erlang实现，为生产者和消费者提供支持。 为什么要“混血”？ 特征 支持Apache Kafka v0.8 + 可靠的生产者实现，支持运行中的请求和异步确认 消费者和生产者都可以在内部处理领导者连任和其他集群干扰 每个brod_client最多打开1个TCP连接到一个代理，如果需要，一个代理可以创建更多客户端 生产者：当未确认（运行中）的请求数超过可配置的最大值时，将自动开始批量处理 生产者：将针对常见错误（例如“不是分区的领导者”）尝试重新发送缓冲的消息，通过刷新元数据自动解决错误 简单使用者：轮询器具有可配置的“预取计数”-只要未处理的消息（不是消息集）的总数小于“预取计数”，它将继续发送取回请求。 群组订户：支持消费者群组，
【文件预览】：
brod-master
----rebar.lock(1KB)
----changelog.md(13KB)
----NOTICE(165B)
----priv()
--------ssl()
----.github()
--------workflows()
----test()
--------brod_consumer_SUITE.erl(31KB)
--------brod_client_SUITE.erl(16KB)
--------brod_SUITE.erl(3KB)
--------brod_group_subscriber_SUITE.erl(24KB)
--------brod_demo_group_subscriber_koc.erl(9KB)
--------brod_group_subscriber_test.hrl(642B)
--------kafka_test_helper.erl(6KB)
--------brod_producer_buffer_SUITE.erl(13KB)
--------brod_test_macros.hrl(888B)
--------brod_producer_SUITE.erl(15KB)
--------brod_compression_SUITE.erl(7KB)
--------brod_demo_topic_subscriber.erl(7KB)
--------brod_test_group_subscriber.erl(3KB)
--------brod_cli_pipe_tests.erl(5KB)
--------brod_group_coordinator_SUITE.erl(5KB)
--------brod_cg_commits_SUITE.erl(4KB)
--------brod_test_setup.hrl(726B)
--------brod_topic_subscriber_SUITE.erl(13KB)
--------brod_cli_tests.erl(7KB)
--------brod_demo_group_subscriber_loc.erl(10KB)
--------brod_utils_tests.erl(3KB)
--------brod_demo_cg_collector.erl(3KB)
--------brod_kafka_apis_tests.erl(3KB)
--------brod_producer_stub_SUITE.erl(15KB)
----rebar.config(614B)
----include()
--------brod.hrl(3KB)
--------brod_int.hrl(3KB)
----LICENSE(10KB)
----sys.config.example(1KB)
----src()
--------brod_cli_pipe.erl(12KB)
--------brod.erl(39KB)
--------brod_kafka_request.erl(7KB)
--------brod.app.src(498B)
--------brod_group_subscriber.erl(25KB)
--------brod_client.erl(32KB)
--------brod_group_coordinator.erl(46KB)
--------brod_producer.erl(24KB)
--------brod_group_subscriber_worker.erl(4KB)
--------brod_group_subscriber_v2.erl(19KB)
--------brod_utils.erl(35KB)
--------brod_cli.erl(44KB)
--------brod_topic_subscriber_cb_fun.erl(2KB)
--------brod_sup.erl(5KB)
--------brod_cg_commits.erl(11KB)
--------brod_topic_subscriber.erl(19KB)
--------brod_consumer.erl(35KB)
--------brod_consumers_sup.erl(6KB)
--------brod_kafka_apis.erl(5KB)
--------brod_group_member.erl(4KB)
--------brod_producers_sup.erl(6KB)
--------brod_producer_buffer.erl(14KB)
----.gitignore(233B)
----rebar.config.script(2KB)
----elvis.config(3KB)
----Makefile(867B)
----README.md(19KB)
----scripts()
--------cover-print-not-covered-lines.escript(3KB)
--------setup-test-env.sh(2KB)
--------brod(600B)
--------docker-compose.yml(1KB)
--------.gitignore(36B)
----contrib()
--------examples()
----.gitattributes(16B)