Skip to content

Latest commit

 

History

History
48 lines (41 loc) · 1.02 KB

README.md

File metadata and controls

48 lines (41 loc) · 1.02 KB

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 :

store