Enriching with currency price

The customer consults the ETH price event, starts in the client's web browser, and is dispatched to Kafka through some HTTP event collector. The second step is to enrich the messages with the geographic location information from MaxMind database. The third step is to enrich the message with the currency price from open exchange rates service.

In summary, here are the architecture steps for the Monedero processing engine:

1. Read the individual events from a Kafka topic called input-messages
2. Validate the message, sending any defective event to a specific Kafka topic called invalid-messages
3. Enrich the message with the geographic location data from MaxMind database
4. Enrich the message with the currency price from open exchange rates service
5. Write the enriched messages in a Kafka topic called valid-messages

The final version of the stream processing...