How would you design an event-driven architecture using Kafka or RabbitMQ for stream processing at Persistent Systems?