Моя команда недавно рассматривала возможность использования различных брокеров сообщений для нашего проекта, в итоге мы выбрали Apache Pulsar, но это относится и к другим (Кафка). Наше требование состоит в том, чтобы отслеживать общее количество отправленных сообщений и байтов, отправленных каждому подписчику для целей выставления счетов.
Я читал документацию по метрикам и был удивлен, увидев, что Pulsar не отслеживает это, я проверил Кафку, и результат был таким же. Мое понимание этого вопроса минимально, так что это своего рода анти-паттерн? Я понимаю, что значения счетчиков, подобные этому, никогда не уменьшаются, а в нашем случае использования не должны сбрасываться, что приводит к потенциальным (определенным) переполнениям. Но для меня это можно решить, используя что-то вроде гистограммы в Prometheus (формат метрик, используемый в Pulsar). Я на самом деле думаю о реализации такой функциональности, но я не прав, и есть ли лучшее решение для нашей цели?