【文件属性】：
文件名称：kaproxy:Kafka 的 Restful HTTP 代理
文件大小：75KB
文件格式：ZIP
更新时间：2021-05-31 12:34:44
Go
卡普罗西
kaproxy 是 kafka 的静态 HTTP 代理，提供以下功能：
基本队列原语：PUBLISH、CONSUME
授权，用户使用令牌访问组和主题
生产/消费者指标
kaproxy SDK
建造
要构建服务器二进制文件：
$ make # target file would be inside _build dir
设计
HTTP API
【文件预览】：
kaproxy-master
----client()
--------errors.go(928B)
--------client.go(8KB)
--------README.md(1KB)
----log()
--------hooks()
--------logger.go(876B)
----server()
--------token_handler.go(3KB)
--------server.go(6KB)
--------route.go(1KB)
--------consumer_group_handler.go(4KB)
--------produce_handler.go(3KB)
--------consumer_handler.go(4KB)
--------middleware.go(1KB)
--------version.go(232B)
--------util.go(297B)
--------admin.go(4KB)
----metrics()
--------metrics.go(5KB)
----config()
--------util_test.go(970B)
--------config.go(5KB)
--------util.go(649B)
----conf()
--------kaproxy-default.toml(606B)
----auth()
--------token.go(8KB)
--------token_test.go(3KB)
----consumer()
--------unack_manager.go(7KB)
--------metadata.go(376B)
--------controller.go(6KB)
--------errors.go(692B)
--------pull.go(7KB)
--------pull_test.go(17B)
--------unack_manager_test.go(3KB)
--------consumer.go(12KB)
--------util.go(2KB)
----xor()
--------xor.go(853B)
----tests()
--------functional()
----test.sh(227B)
----main.go(1KB)
----producer()
--------replication.go(8KB)
--------errors.go(243B)
--------producer.go(4KB)
----.gitignore(339B)
----Changelog(39B)
----Makefile(626B)
----go.sum(16KB)
----README.md(362B)
----lint.log(0B)
----util()
--------zk.go(2KB)
--------unique_id.go(479B)
--------multipart_parser.go(1KB)
--------recover_test.go(156B)
--------recover.go(913B)
----scripts()
--------docker-datacenter-2()
--------stop.sh(81B)
--------503.sh(535B)
--------bench-produce.sh(90B)
--------200.sh(534B)
--------bench-consume.sh(151B)
--------restart.sh(115B)
--------bench-produce-http.lua(140B)
--------start.sh(82B)
--------README.md(1KB)
--------docker-datacenter-1()
--------status.sh(132B)
----build.sh(2KB)
----go.mod(659B)