kafka-streams-join

How to run?

• Ensure you have Java 8, Scala 2.11, SBT and the latest Confluent platform installed
• Start the Kafka cluster, Zookeeper must be reachable at localhost:2181 and Kafka broker at localhost:9092
• Run tests using sbt clean test

Interesting things

• TopicShifter class, that spawns a Topology that create a new time-shifted topic from input one.
• TimeoutJoinTest test cases, that shows how to emit an even when no-join occurred.

Referring topics on the confluent-platform user group

• Process a Kafka topic with a delay using Kafka Stream
• [Kafka Streams] Detect absence of join after a time period