Я пишу приложение Spring Boot, которое потребляет большое количество каналов kafka.Миллионы данных постоянно.Каждый канал должен быть сохранен в postresql, и необходимо добавить некоторые дополнительные значения, которые будут получены из остальных API.В основном это часть обогащения.Сервер API, который предоставляет эту информацию об обогащении, может обрабатывать только 2-8 запросов в секунду и не может ее контролировать.Каков эффективный и стабильный способ реализации этого?данные не должны быть потеряны, стабильность и эффективность также учитываются.
![enter image description here](https://i.stack.imgur.com/xbQJA.png)