Концептуально задача такая, есть Кафка и сервис, который берет событие и дополняет его инфой, для чего делает условно rest в другую систему. У системы есть SLA в виде ограничения tps
Не делать REST call из стримов - класть назад в Кафку и коннектором класть в REST service