Eine verfügbare Bibliothek ist sarama (oder ihre Erweiterung sarama-cluster), jedoch wird kein Beispiel für eine Verbrauchergruppe angegeben, nicht in sarama noch in sarama-cluster.Wie erstelle ich eine Kafka Verbrauchergruppe in Golang?
Ich verstehe die API nicht. Kann ich ein Beispiel für die Erstellung einer Verbrauchergruppe für ein Thema haben?
Die Consumer-Gruppe wird durch das zweite Argument des Cluster Consumers "Constructor" angegeben. Hier ist eine sehr einfache Skizze:
import (
"github.com/Shopify/sarama"
"github.com/bsm/sarama-cluster"
)
conf := cluster.NewConfig()
// add config values
brokers := []string{"kafka-1:9092", "kafka-2:9092"}
group := "Your-Consumer-Group"
topics := []{"topicName"}
consumer := cluster.NewConsumer(broker, group, topics, conf)
Und so werden Sie ein Verbraucher an die angegebene Verbrauchergruppe gehören, haben.