【文件属性】：
文件名称：sarama-cluster：Sarama的集群扩展，Apache Kafka 0.9的Go客户端库[已弃用]
文件大小：32KB
文件格式：ZIP
更新时间：2021-02-03 14:20:40
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)