KSD

KSD offers a debug UI for Kafka Streams

Import

Add the repository :

<repositories>
    <repository>
        <id>jitpack.io</id>
        <url>https://jitpack.io</url>
    </repository>
</repositories>

Add to your pom.xml

<dependency>
    <groupId>com.rocel</groupId>
    <artifactId>ksd</artifactId>
    <version>0.1.0</version>
</dependency>

How to use

KSDBase ksd = new KSD();
ksd.start(kStreams, 5000, "localhost:2181");
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    ksd.stop();
});

KSD#start() parameters :

• kStreams : KafkaStreams instance
• 5000 : port on which the KSD will be listening
• "localhost:2181" : URI of the Zookeeper on which the Kafka broker is running

Features

• List all topics used in the topology
• Show information about a selected topic
• List all stores used in the topology
• Show all the data of specified store
• Search in the data of a specified store

Screenshots

Show all the data of a specified store :