Alexey Zimarev
Alexey Zimarev
We keep getting this questions from people who use message buses to build read models, it is the FAQ question, but it is still here https://github.com/gregoryyoung/m-r/blob/master/CQRSGui/Global.asax.cs#L45 Be May it is...
It seems that the periodic checkpoint callback set in server-side filter options only when in catch-up mode. When the subscription gets real-time, the callback is not called. As the result,...
Right now, we expect the private key to be the RSA private key but it's just an assumption. The private key format is defined by its header and different RSA...
@alexeyzimarev: I've got a very crude implementation of subscriptions using polling: https://github.com/claudiuchis/eventsourcing.sql. I have created tests to cover the event store, aggregate and subscriptions (all stream, single stream), for now...
The current command handling flow looks like this: * Load the aggregate * Call the model * Persist new events When the last step fails due to an optimistic concurrency...
Aiming to solve the following scenario: - We are importing data from a legacy system directly to the events archive (Elastic) - There's one event per aggregate in the archive,...
Storing commands with their ids allows tracing events back to commands, building the full chain of actions and reactions. Also useful for failure tracking, as the command payload can tell...
Subscribe to Kafka topics without using schema registry, expect `byte[]` as the payload. If the partition key is provided, use it as the partition key for parallel consume.