没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
Kafka-Pixy(用于Kafka的gRPC / REST代理) Kafka-Pixy是具有自动使用者组控制的双重API(gRPC和REST)代理。 它旨在隐藏Kafka客户端协议的复杂性,并提供一个愚蠢的简单API,可以用任何语言轻松实现。 Kafka-Pixy已针对Kafka 1.1.1和2.3.0版本进行了测试,但可能适用于0.8.2.2以后的任何版本。 它使用Kafka 来跟踪消费者抵销。 但是, 尚未实现,因此需要直接与Zookeeper对话以管理消费者组成员身份。 警告:Kafka-Pixy不支持通配符订阅,因此不能与使用它们的客户端共存于消费者组中。 如果他们通过全名订阅主题,则应该有可能使用与kafka-pixy实例在同一消费者组中的其他客户端,但是从未经过测试,这样做后果自负。 如果您急于入门,请Kafka-Pixy并继续使用所选武器的快速入门指南: , 或 。 如果您想使用其他语言,则仍然可以使用其中的任何指南作为灵感,但是您需要自己从生成gRPC客户端存根(有关详细信息,请参阅)。 主要特点: 自动使用者组管理:与不同,客户端不需要显式创建使用者实例
资源推荐
资源详情
资源评论
收起资源包目录
kafka-pixy:Kafka的gRPCREST代理 (104个子文件)
kafka.conf 313B
zookeeper.conf 199B
toxiproxy.conf 96B
client.crt 2KB
ca.crt 1KB
Dockerfile 454B
.gitignore 311B
kafkapixy.pb.go 50KB
service_http_test.go 40KB
msgfetcher_test.go 28KB
consumerimpl_test.go 25KB
config.go 24KB
offsetmgr_test.go 24KB
httpsrv.go 23KB
service_grpc_test.go 20KB
subscriber_test.go 19KB
partitioncsm_test.go 19KB
msgfetcher.go 17KB
offsetmgr.go 15KB
multiplexer_test.go 15KB
mapper_test.go 13KB
main.go 13KB
offsettrk_test.go 13KB
admin.go 13KB
offsettrk.go 12KB
kazoo.go 11KB
dispatcher_test.go 11KB
grpcsrv.go 11KB
groupcsm.go 11KB
proxy.go 10KB
kazoo_test.go 10KB
topiccsm_test.go 10KB
mapper.go 9KB
partitioncsm.go 9KB
subscriber.go 8KB
dispatcher.go 8KB
multiplexer.go 8KB
producer.go 8KB
record_easyjson.go 6KB
kafkahelper.go 6KB
producer_test.go 6KB
main.go 5KB
topiccsm.go 5KB
config_test.go 4KB
testconsumer.go 4KB
record.go 4KB
groupcsm_test.go 4KB
testproducer.go 4KB
prettyfmt.go 4KB
service.go 3KB
logging.go 3KB
admin_test.go 3KB
offsetmgr_func_test.go 3KB
consumerimpl.go 3KB
formatter.go 3KB
msgfetcher_func_test.go 3KB
consumer.go 3KB
json.go 2KB
actor.go 2KB
prettyfmt_test.go 2KB
testhelpers.go 2KB
actor_test.go 1KB
event_reader.go 960B
service_test.go 929B
proxyset.go 890B
json_test.go 862B
event_reader_test.go 798B
main.go 570B
server.go 533B
none.go 43B
client.key 3KB
LICENSE 11KB
Makefile 922B
README.md 20KB
CHANGELOG.md 7KB
quick-start-python.md 6KB
quick-start-golang.md 4KB
quick-start-curl.md 2KB
howto-install.md 735B
README.md 275B
go.mod 1KB
server.properties 5KB
zookeeper.properties 1KB
kafkapixy.proto 12KB
kafkapixy_pb2.py 51KB
kafkapixy_pb2_grpc.py 7KB
install_cluster.sh 2KB
setup_services.sh 2KB
boot_cluster.sh 1KB
release.sh 1KB
shutdown_cluster.sh 1KB
run_toxiproxy.sh 756B
travis_build.sh 543B
gen-grpc.sh 521B
create_topics.sh 435B
provision.sh 383B
build-image.sh 132B
go.sum 22KB
Vagrantfile 525B
kafka-tls.yaml 8KB
共 104 条
- 1
- 2
资源评论
想变得很厉害
- 粉丝: 45
- 资源: 4730
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 上海旅游统计数据-入境外国人按主要客源国分(人次)数据集
- Python基础-01:注释、变量、计算、打印
- c++冒泡排序从小到大,初学者使用
- AI进展下ChatGPT对文献情报工作的影响及启示
- 个人笔记的回归分析学习笔记-2
- HengCe-2024-2030中国棕榈脂肪粉市场现状研究分析与发展前景预测报告 -样本-lujing.docx
- 图解socket级别的sk-forward-alloc分配
- 北京市教育领域人工智能应用指南.pdf
- HengCe-18900-2024-2030全球与中国镀锌铝钢丝市场现状及未来发展趋势-样本.docx
- Hive函数实例数据The-NBA-Championship.txt
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功