如何在Golang中创建kafka消费者组？

小编典典

如何在Golang中创建kafka消费者组？

可用的库是sarama（或其扩展sarama-
cluster），但是没有提供消费者群体示例，在sarama或sarama-cluster中均未提供。

我不了解API。我可以举一个为主题创建消费者组的示例吗？

阅读 1849

2020-07-02

共1个答案

小编典典

消费方组由集群消费方“构造函数”的第二个参数指定。这是一个非常基本的草图：

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 := []string{"topicName"}
consumer := cluster.NewConsumer(broker, group, topics, conf)

因此，您将拥有一个属于指定消费者组的消费者。

2020-07-02