Conduktor allows you to monitor your Kafka Streams applications and do the links with the existing topics, consumer groups etc. that the Kafka Streams application is using.
IMPORT TOPOLOGY,
then:
application.id
of your applicationmyapplicationid
and exposing a endpoint /topology
:
Topology
object in your Java/Scala/Kotlin code.
For instance, when your program starts, you can simply emit the Topology on stdout to copy/paste it:
"/topology"
that returns the result of topology.describe()
, that you can use in Conduktor.