У меня есть приложение, которое использует потоки проектного реактора и flatMap для обработки запросов из очереди сообщений.
Каждый из flatMap в цепочке потоков подписывает элементы на предварительно созданные планировщики. Flux создается с помощью BUFFER в качестве стратегии переполнения противодавления.
Мы разрешили реактору публиковать sh метрики и нанесли на график то же самое в Grafana
Хотите знать, если есть способ получить указатель на текущий размер буфера - так, чтобы тот же самый мог быть передан в Grafana для нас, чтобы мы наблюдали
flatMap - согласно моему пониманию создает внутренние потоки. Есть ли способ контролировать размер невыполненных задач / буфера для этих внутренних потоков?
Как только я получу эту информацию, это поможет мне увидеть, какой flatMap занимает некоторое время для обработки (медленный потребитель) и может соответствующим образом настроить цепь Flux.