文件名称：kafka-client:转到Apache Kafka的客户端库
文件大小：93KB
文件格式：ZIP
更新时间：2024-05-04 13:02:25
go kafka Go
转到Kafka客户端库 Apache Kafka的高级Go客户端库，在之上提供以下原语： 与死信队列（DLQ）竞争的消费者语义 能够跨多个goroutine处理消息 能够无序确认或否定消息（带有可选的DLQ） 能够从分布在不同kafka集群中的主题进行消费 稳定 该库为Alpha版本。 API可能会更改，使用后果自负 贡献 如果您有兴趣进行贡献，请签署并参阅我们的 安装 go get -u github.com/uber-go/kafka-client 快速开始 package main import ( "os" "os/signal" "github.com/uber-go/kafka-client" "github.com/uber-go/kafka-client/kafka" "github.com/uber-go/tally" "go.uber.org/zap
【文件预览】：
kafka-client-master
----Gopkg.toml(1KB)
----.gitignore(58B)
----version(12B)
----.codecov.yml(762B)
----Makefile(2KB)
----consumerOptions.go(3KB)
----.travis.yml(277B)
----consumerBuilder_test.go(7KB)
----LICENSE(1KB)
----CHANGELOG.md(2KB)
----scripts()
--------cover.sh(220B)
----consumerBuilder.go(13KB)
----README.md(3KB)
----consumerOptions_test.go(2KB)
----kafka()
--------config_test.go(2KB)
--------interfaces.go(5KB)
--------resolver.go(3KB)
--------resolver_test.go(3KB)
--------config.go(7KB)
----client.go(2KB)
----Gopkg.lock(5KB)
----glide.lock(2KB)
----docs()
--------DEVELOPMENT-GUIDE.md(879B)
----client_test.go(4KB)
----cmd()
--------tools()
----glide.yaml(405B)
----internal()
--------list()
--------util()
--------backoff()
--------consumer()
--------metrics()