Skip to content

Latest commit

 

History

History
13 lines (8 loc) · 780 Bytes

kafka-streams-exercise-Processing-Record-Stream-with-KStream.md

File metadata and controls

13 lines (8 loc) · 780 Bytes

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