Skip to content

Kafka Streams simple implementation providing a REST server, and compatible with Conduktor

Notifications You must be signed in to change notification settings

conduktor/kafka-streams-wordcount-topology

Repository files navigation

Kafka Streams WordCount - Conduktor Compatible (with Topology webserver)

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 topology topology.describe()

This allows

  • to visualize the topology online
  • to monitor and reset the topology in Conduktor

Conduktor Kafka Streams Setup

The topology is at http://localhost:8080/topology

Documentation at: https://docs.conduktor.io/features/kafka-streams

Setup in Conduktor:

Conduktor Config Streams

Monitoring and Reset Capabilities

Conduktor Monitor Streams

About

Kafka Streams simple implementation providing a REST server, and compatible with Conduktor

Topics

Resources

Stars

Watchers

Forks

Languages