I have a successfull implementation of the events replay using the tracking event processor.
The PROBLEM is, it seems like the tracking event processor is reading events directly from the events store rather than the event bus.
So, any time the command service pushes a new event (To Event Store and Event Bus) the event handler on query side is invoked and it consumes the event from the store rather then the bus.
My Application Config
App: Spring Boot
Event Bus: Rabbit MQ
Event Store: MongoDB
I want to ask is this the correct design and behavior for a tracking processor?