如何在Golang中創建一個kafka消費者羣體？

Question

一個可用的庫是sarama（或它的擴展sarama-cluster）但是沒有提供消費者組示例，而不是在sarama也不在sarama-cluster。

我不明白的API。我可以舉一個例子來爲一個話題創建一個消費者羣體嗎？

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

所以你將有一個消費者屬於指定的消費者羣體。