Consuming events from a message broker