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

  • Z时代
  • 2024-01-10
  • 分类：问答

可用的库是sarama（或其扩展sarama-

cluster），但是没有提供消费者群体示例，在sarama或sarama-cluster中均未提供。

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

回答：

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

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)

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

以上是 如何在Golang中创建kafka消费者组？ 的全部内容， 来源链接： utcz.com/qa/434957.html

回到顶部