Application loads sentences from file (each line is one sentence), then each sentence is send to Kafka by kafka producer.
By using Kafka Streams then sentences are modified to another topic. Modification consists of string trim, character elimination (characters can be parametrized).
The goal is make a snake from words in each sentence, for that, the modification process contains of step, which make a sentence valid for a snake, i.e the first character of each word (except) is the same as the last word of the previous word in a sentence.
Kafka cluster is created by docker-compose.yml.
Make sure to have running docker containers before start the application
Integration tests depend on external kafka cluster (from docker). Make sure to start containers before running integration tests