How to read the topology from Kafka using Clojure?

Viewed 18

On this page https://zz85.github.io/kafka-streams-viz/ visualization is given for the Kafka Streams Topology. However is uses a static form field for this visualization. I want to be able to this automatically. Therefore I'm trying to use Clojure to read the topology from a running environment. I think I can use the Java library org.apache.kafka.streams for this, see https://kafka.apache.org/23/javadoc/index.html?org/apache/kafka/streams/Topology.html. It has a class Topology with a method TopologyDescription or describe(). I hope that this is the method to be called which will return me the topology as shown in this page https://zz85.github.io/kafka-streams-viz/

How can I call this method in Clojure?

0 Answers
Related