А вообще на одном стартапе мне показали, как они имплементируют cqrs + es. Там всё по-другому. В топики кафки попадают мутации, через кафка стримы создают снапшоты для read операций и через кафка коннект данные в фоне в бд попадают на постоянное хранение. Я после этого так и заинтересовался этой mq