KART (Kafka Automatic Referral Triage)

Description

Mario is an healthcare professional working at the Nintendo Cars Garage, where players go if they have incidents during the the races. Every car has a "black box" containing a log in text format with recents events. The last line has a special code defining the status of the car. Mario would like to dispatch automatically the cars according to the level of damage indicated in the status in two queues:

• recoverable: cars that can be repaired
• scrap: cars that need to be demolished

Challenge

Help Mario implementing a system based of files sent via httpd (choose the format, remember to be able to distinguish the status in the last line) send to Kafka and using Kafka Stream perform a triage and sent to the appropriate topic Use kafka consumer to show the status of the queues

Prerequisites

Build Stream App

To start the project run

cd kart-stream
docker build . --tag kart

Execution

Run

docker-compose -f kart.yml up

To send message to KART using curl

## Log message of car unrecoverable
curl -d"Luigi SYS64738" http://localhost:9090

## Log message of car for garage
curl -d"Mario OK" http://localhost:9090

To stop press CTRL+C

Remove containers

docker-compose -f kart.yml down

Implementation Details

Archetype

mvn archetype:generate \
    -DarchetypeGroupId=org.apache.kafka \
    -DarchetypeArtifactId=streams-quickstart-java \
    -DarchetypeVersion=3.7.0 \
    -DgroupId=tap.kart \
    -DartifactId=kart-stream