Please have a look at the parent README first.
A Kafka Streams application. It reads arrays of Zipkin Spans from an input Kafka topic and calculates slowdowns, i.e., whether response times exceed a specified threshold or not. We calculate slowdowns per window. Windows advance by some hopping interval (and may overlap). The resulting window stream consists of a key (includes the host IP) and a value (0 for no slowdown, 1 for a slowdown).
Please have a look at the parent README that explains building and running the extraction with Gradle and Docker Compose. This project will be built as part the parent a multi-project.
Have a look at the implementation and test of the application.