Description
Motivation
- To support both message queues seamlessly, the redis_client needs to be replaced to an abstract message queue which can support both kafka and redis_client
Required Features
- Add the kafka service to docker-compose file
- Implement an abstract class for the abstract message queue
- Modify the EventDispatcher and EventProducer accordingly
Impact
- Affects
events.py
under common and the docker-compose file
Testing Scenarios
- Test the message queue feature
Metadata
Metadata
Assignees
Labels
No labels