文件名称：sarama-cluster：Sarama的集群扩展，Apache Kafka 0.9的Go客户端库[已弃用]
文件大小：32KB
文件格式：ZIP
更新时间：2024-02-24 08:07:20
go kafka deprecated consumer sarama
萨拉玛群集 集群扩展，Apache Kafka 0.9（及更高版本）的Go客户端库。 停产通知 请注意，由于已合并并发布（> = v1.19.0），因此该库已正式弃用。 本机实现支持该库无法提供的各种用例。 文献资料 可通过godoc在中获得文档和示例 例子 消费者有两种操作模式。 在默认的多路复用模式下，多个主题和分区的消息（和错误）都传递到单个通道： package main import ( "fmt" "log" "os" "os/signal" cluster "github.com/bsm/sarama-cluster" ) func main () { // init (custom) config, enable errors and notifications config := cluster . NewConfig () config . Consumer . Return . Errors = true config . Group . Return . Notifications = true // init consumer bro
【文件预览】：
sarama-cluster-master
----README.md.tpl(2KB)
----balancer_test.go(4KB)
----cluster.go(681B)
----client.go(933B)
----testdata()
--------zookeeper.properties(77B)
--------server.properties(469B)
----offsets.go(2KB)
----offsets_test.go(2KB)
----client_test.go(799B)
----Gopkg.toml(610B)
----balancer.go(5KB)
----config_test.go(622B)
----consumer.go(23KB)
----cluster_test.go(5KB)
----util.go(1KB)
----.travis.yml(352B)
----LICENSE(1KB)
----consumer_test.go(12KB)
----doc.go(300B)
----examples_test.go(3KB)
----Gopkg.lock(4KB)
----README.md(4KB)
----Makefile(894B)
----partitions_test.go(4KB)
----.gitignore(28B)
----partitions.go(6KB)
----cmd()
--------sarama-cluster-cli()
----config.go(5KB)