Как справиться с противодавлением в весеннем облаке с реактивным паром

Я использую Spring Cloud для использования темы Kafka, выполнения некоторой обработки и сохранения результата в базе данных Mongo. Я заметил, что, если мой потребитель медленно обрабатывает данные, потребление памяти быстро растет, пока служба не будет отключена.

Дальнейший анализ показал, что облако Spring по умолчанию использует стратегию обратного давления BUFFER, и, следовательно, буфер заполняется и съедает всю память.

Мой вопрос: есть ли способ в облаке Spring указать стратегию обратного давления (а не просто буфер)? а если нет, есть ли способ ограничить / настроить размер буфера?

0 ответов