Is your feature request related to a problem? Please describe.
Need to implement database storage for trade execution records through RocketMQ consumer.
Describe the solution you'd like
Implement RocketMQ consumer for trade record storage:
- Consume trade events from RocketMQ
- Store trade details in database
- Handle duplicate messages
- Implement retry mechanism for DB failures
Describe alternatives you've considered
- Direct DB write: No resilience
- Event sourcing: Too complex for requirement
- Batch processing: Higher latency
Additional context
Add any other context or screenshots about the feature request here.