Пополнить источник события агрегат с кафкой в качестве хранилища событий
Все больше и больше статей рассказывают о kafka как хранилище событий и использовании его в приложении, построенном с использованием cqrs & Event Sourcing. Как вы запрашиваете kafka (как хранилище событий) для событий определенного агрегата, чтобы завершить операцию на стороне записи?
1 ответ
Вы можете использовать Kafka Streams ( http://docs.confluent.io/current/streams/index.html) для вычисления совокупности данных, хранящихся в Kafka. В следующем выпуске (голосование уже продолжается) Kafka Streams добавляет новую функцию под названием " Интерактивные запросы", которая позволяет запрашивать текущее значение каждого агрегата в любое время.
Смотрите проектный документ на данный момент (все еще со старым названием функций "Queryable State") https://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A+Queryable+state+for+Kafka+Streams
После релиза будет подробная документация о том, как работают интерактивные запросы. Если у вас есть следующий вопрос, просто продолжайте.