sarama cluster:Sarama的集群扩展Apache Kafka 0.9的Go客户端库[已弃用] 源码

萨拉玛群集 集群扩展,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 () { // in