文件名称：kafboy:使用 Cowboy、ekaf 和 poolboy 将事件发送到 Kafka 0.8 代理的 HTTP 服务器
文件大小：26KB
文件格式：ZIP
更新时间：2024-07-20 11:22:26
Erlang
卡夫男孩 用于写入 kafka 的低延迟 http 服务器。 针对重负载、数百个分区工作器进行了优化，支持批处理等。 用 Erlang 写的。 由ekaf和Cowboy提供支持 有关更多信息，请参阅 建筑学 在 0.8 版本中，Kafka 客户端承担更大的责任来决定将给定主题发布到哪个代理和分区。 kafboy 是 ekafka 客户端上的 http 包装器，负责将 http 请求路由到正确的 kafka 代理套接字。 kafboy 在集群上具有自我意识，并且支持节点将到达任何节点的请求路由到集群中的正确进程。 只需将带有所需 JSON 的 POST 发送到以下路径之一 火与遗忘 % fire and forget asynchronous call. the event is immediately send to kafka asynchronously POST /async
【文件预览】：
kafboy-master
----benchmarks()
--------n30000_c100_strategy_sticky_batch.png(6KB)
--------n30000_c100_strategy_random.png(6KB)
----src()
--------kafboy_logger.erl(716B)
--------kafboy_startup_worker.erl(9KB)
--------kafboy_http_handler.erl(6KB)
--------kafboy_producer.erl(587B)
--------kafboy.app.src(422B)
--------kafboy_sup.erl(4KB)
--------kafboy_app.erl(4KB)
--------kafboy_disco_handler.erl(1KB)
----rel()
--------vars.config(0B)
--------reltool.config.sample(3KB)
----README.md(6KB)
----rebar.config(769B)
----.gitignore(101B)
----include()
--------kafboy_definitions.hrl(2KB)
--------kafboy_records.hrl(242B)