[ Data Producer ] ▶ producer.py # 模擬高頻率資料流產生
│ │
│ └── [ Kafka Topic: 'test-data' ]
▼
[ Data Consumer ] ▶ consumer.py
│
├── Read from Kafka
│
├── Write to Redis
│
└── Write to MongoDB








