How would you design a real-time streaming architecture using Kafka for live marketplace monitoring at TaskRabbit?