Golangでカフカコンシューマーグループを作成するには？

Question

利用可能なライブラリはsarama（またはその展開sarama-cluster）ですが、saramaでもsarama-clusterではなく、消費者グループの例は提供されていません。

私はAPIを理解していません。トピックのコンシューマ・グループを作成する例がありますか？

Answer 1

コンシューマグループは、クラスタコンシューマ "コンストラクタ"の2番目の引数で指定します。

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) 

だから、あなたが指定したコンシューマ・グループに属する消費者があるでしょう。ここでは非常に基本的なスケッチです。