У меня в проекте похожая схема. В проекте с read-model есть ручки для изменения сущностей write-model-и. При формировании http запроса на него нашлепывается operation-id в хедере. Этот же id пишется в хедер кафки. Пока сервис с read-model-и не обработал event с таким operation-id, он не отдаст ответ на запрос. Ну еще подкостылили ожидание в 2 секунды, если уж совсем долго ивент идет или обрабатывается. Пока по башке не получили за такое решение, вроде работает)
У меня в проекте похожая схема. В проекте с read-model есть ручки для изменения сущностей write-model-и. При формировании http запроса на него нашлепывается operation-id в хедере. Этот же id пишется в хедер кафки. Пока сервис с read-model-и не обработал event с таким operation-id, он не отдаст ответ на запрос. Ну еще подкостылили ожидание в 2 секунды, если уж совсем долго ивент идет или обрабатывается. Пока по башке не получили за такое решение, вроде работает)