0

sarama を使用して kafka プロデューサー/コンシューマー メトリックを取得しようとしています。しかし、同じことを行う方法の例を見つけることができません。誰かがサンプル実装例を提供できますか?

次のコードを使用して、ブローカーのメトリックを取得しています。しかし、プロデューサー/コンシューマーのメトリックを取得するための構成はどうあるべきですか? 私はそれが同じではないだろうと仮定しています。間違っていたら訂正して

    saramaConfig := sarama.NewConfig()
    saramaConfig.Version = <BrokerVersion>
    client, err := sarama.NewClient(<brokerAddresses>, saramaConfig)
    if err != nil {
        log.Println("Unable to create sarama client")
        panic(err)
    }
    config := client.Config()

    MeanIncomingByteRate := metrics.GetOrRegisterMeter(getMetricNameForTopic("incoming-byte-rate", topic), config.MetricRegistry).RateMean(),
4

1 に答える 1