文件名称:siesta:在Go中更好地支持Apache Kafka
文件大小:66KB
文件格式:ZIP
更新时间:2024-05-17 06:26:09
Go
午休 Go中的低级Apache Kafka库 安装: 安装Golang 确保存在环境变量GOPATH和GOROOT并指向正确的位置 go get github.com/elodina/siesta go test -v以确保它可以正常工作 您可能还希望在localhost:9092启动本地代理,以使功能测试也正常工作(否则将被跳过)。
【文件预览】:
siesta-master
----.gitignore(285B)
----offset_fetch.go(5KB)
----join_group.go(4KB)
----describe_groups.go(5KB)
----connector_test.go(5KB)
----offset_commit.go(4KB)
----fetch_test.go(11KB)
----list_groups_test.go(2KB)
----encoder_decoder_test.go(7KB)
----.travis.yml(1KB)
----offset_test.go(6KB)
----snappy.go(656B)
----brokers.go(4KB)
----LICENSE(11KB)
----heartbeat.go(2KB)
----list_groups.go(2KB)
----fetch.go(7KB)
----join_group_test.go(3KB)
----README.md(556B)
----connector.go(22KB)
----describe_groups_test.go(2KB)
----consumer_metadata_test.go(3KB)
----util.go(1KB)
----topic_metadata_test.go(9KB)
----decoder.go(4KB)
----request_response.go(3KB)
----produce.go(4KB)
----offset.go(5KB)
----utils_test.go(4KB)
----produce_test.go(4KB)
----consumer_metadata.go(3KB)
----leave_group_test.go(2KB)
----metadata.go(6KB)
----request_response_test.go(1KB)
----logger.go(7KB)
----encoder.go(7KB)
----offset_commit_test.go(4KB)
----sync_group_test.go(2KB)
----topic_metadata.go(7KB)
----offset_fetch_test.go(4KB)
----errors.go(7KB)
----messages.go(6KB)
----leave_group.go(2KB)
----sync_group.go(2KB)
----heartbeat_test.go(2KB)