kafka-workshop

Exercise: Processing Record Stream with KStream

Develop a standalone Kafka Streams application (using IntelliJ IDEA) that reads records in from a source and writes it out to a sink.

1. Use the high-level Streams DSL
2. Use StreamsBuilder.stream to create a KStream to read records in
3. Use KStream.to to write records out

In the end, use sbt assembly and java -jar to run the application.

Module: Kafka Streams

Duration: 30 mins

This site is open source. Improve this page.