У меня есть такой паттерн, продьюсеры пишут сообщения разных типов: девайс, юзер, лицензия. Каждый в свой топик, но у каждого одинаковый составной ключ. Консьюмеры это дело чуть трансформируют и пихают по ключу в Кассандру, в одну таблицу и получается полный профиль клиента, который апдейтится. Потом это идёт опять в кафку и в S3, где уже происходит анализ данных. Т.к. происходит только эволюция схемы, то синхронный апгрейд версии схемы ни к чему не обязывает и всё продолжает работать.