This is just the standard Apache Kafka wordcount application with:
- the Topology description logged
System.out.println(topology.describe());
- a web server with a route
http://localhost:8080/topology
that returns the topologytopology.describe()
This allows
The topology is at http://localhost:8080/topology
Documentation at: https://docs.conduktor.io/features/kafka-streams