Я использую Spring Cloud, чтобы использовать топик Кафки c, выполнить некоторую обработку и сохранить результат в базе данных Mon go. Я заметил, что если мой потребитель медленно обрабатывает, то потребление памяти быстро увеличивается, пока сервис не останавливается.
Дальнейший анализ показал, что облако Spring использует стратегию противодействия BUFFER по умолчанию, и, следовательно, буфер заполняется и пожирает всю память.
Мой вопрос: есть ли способ в облаке Spring указать стратегию противодавления (а не просто буфер)? и если нет, есть ли способ ограничить / настроить размер буфера?