文件名称：erlang-kafka:Erlang 的 Kafka 消费者协议
文件大小：28KB
文件格式：ZIP
更新时间：2024-07-12 23:35:53
Erlang
Erlang Kafka 客户端 EKC 是的 Erlang 客户端，目前提供的消费者 API，是一个高吞吐量的分布式消息传递系统。 建造 EKC 使用 。 要构建运行make 。 客户 Kafka 协议客户端作为 OTP gen_server运行。 范围 描述 默认 笔记 主持人 要连接的 Kafka 代理的主机名 本地主机 主机名或 IP 地址作为元组 港口 Kafka 代理使用的端口号 9092 客户编号 发送给 Kafka 代理的客户端 ID <<"ekc">> 连接： { ok , C } = ekc : start ([{ host , { 172 , 16 , 1 , 186 }}]). 或者当作为监督层次结构的一部分包括在内时： { ok , C } = ekc : start_link ([{ host , { 172 , 16 , 1 , 186 }}
【文件预览】：
erlang-kafka-master
----.travis.yml(215B)
----Emakefile(91B)
----LICENSE(11KB)
----src()
--------ekc_broker.erl(942B)
--------ekc_application.erl(1000B)
--------ekc_protocol.erl(2KB)
--------ekc_topic.erl(1016B)
--------ekc_protocol_metadata.erl(3KB)
--------ekc_protocol_consumer_metadata.erl(1KB)
--------ekc_message_set.erl(1KB)
--------ekc_partition.erl(2KB)
--------ekc_metadata.erl(927B)
--------ekc.erl(8KB)
--------ekc.hrl(2KB)
--------ekc_supervisor.erl(850B)
--------ekc_protocol_offset.erl(2KB)
--------ekc_protocol_fetch.erl(3KB)
--------ekc.app.src(223B)
----erlang.mk(19KB)
----.gitignore(8B)
----start.sh(718B)
----Makefile(62B)
----README.md(4KB)