- Start kafka docker-compose
--file=Docker-compose-kafka.yml up -dor set environment variable for servicesKAFKA=localhost:29092 - Run source application
- Run processor application
Open http://localhost:8090 (Kafka UI) and see topics and message
Produces StreamRequest every 15 seconds to input-topic
Listening input-topic, proceed messages (add to StreamRequest.data list "Processed") and send to output-topic