В настоящее время у нас запущены два экземпляра одного потокового приложения.Метрики сообщаются правильно, пока оба работают.Когда мы закрываем одно из потоковых приложений, все метрики на работающем экземпляре сбрасываются в 0. Почему?Это ожидаемое поведение?
Мы используем KafkaStreams # allMetadata () для получения метрики из удаленных экземпляров приложения и KafkaStreams # metrics () для получения локальных данных метрики.Я знаю, что это не время, так как количество сэмплов установлено на большое количество, поэтому они не сбрасываются на устаревшие данные.
Мы используем 1.1.1
Подробнеео том, как мы получаем их из удаленного приложения: KafkaStreams # allMetadata () возвращает список StreamsMetadata, который имеет хост и порт удаленного приложения.Мы делаем вызов покоя этому хосту и конечной точке отдыха, которую я создал.Эта конечная точка отдыха возвращает результат KafkaStreams # metrics ().Все это работает.Когда приложение покидает кластер, все показатели сбрасываются до 0. Я вижу это также в jconsole.