Получение метрик kafka с использованием библиотеки go sarama - PullRequest
Новая
       37

Получение метрик kafka с использованием библиотеки go sarama

0 голосов
/ 07 апреля 2020

Я пытался получить показатели брокера kafka, используя go библиотеку sarama, и у меня мало вопросов.

Я инициализировал конфигурацию sarama с помощью sarama.NewConfig () с версией sarama.V2_0_0_0 и Я использовал эту конфигурацию для получения метрик, как указано в их do c

`metrics.GetOrRegisterMeter("incoming-byte-rate", config.MetricRegistry).RateMean()`

  1. Обеспечивает ли это общую скорость входящих байтов, включая все входящие сообщения? Потому что я сравнил это значение с объективами и другими инструментами, но оно совершенно другое (то же самое для «скорости исходящих байтов» и «скорости запросов». Я полагаю, что эта частота запросов подразумевает скорость сообщений).

  2. В отличие от функции RateMean(), Rate1(), Rate5() и Rate15() возвращают только 0, хотя в кластере kafka достаточно активности. Вы знаете какие-либо причины для этого?

  3. Я использовал metrics.GetOrRegisterMeter(fmt.Sprintf("incoming-byte-rate-for-broker-%v", broker.ID()), config.MetricRegistry).RateMean() для получения метрик уровня брокера, как указано в do c, но я получил только 0.

Я был бы очень признателен, если бы кто-нибудь помог мне здесь и разъяснил мне эти проблемы. Заранее спасибо. :)

...