/kafka-streams-rename-topics-scala

Show how to use a single Kafka Streams app to rename a set of input topics

Primary LanguageScala

Shows how to use a simple Kafka Streams Topology to rename a set of topics by removing their prefix, leveraging:

  • the .stream(Pattern.compile("...")) builder pattern
  • using a TopicNameExtractor (which falls down to a simple functions taking key, value, and record context as input parameters and returning a String as output)
  • testing this using TopologyTestDriver

Running:

./sbtx test