...
Only basic validation is performed on the event producing stage:
- json validation
- job hash check
- in case there is no job with the same hash in status pending, create job in MongoDB
- Otherwise, we will respond with 202 (accepted) but with the previously created job id. New job will not be created in Mongo DB
- message with the relevant type is created in Kafka medical_events topic
- medical_events topic has multiple partitions
- Messages related to the same patient always must be sent to the same partition.
...