example-kafkastreams
example-kafkastreams copied to clipboard
Kafka Streams DSL vs Processor API
Kafka Streams DSL vs Processor API
Features
- Warm-up Processor API exercise, see DeduplicationExample.
- Clickstream join topology implemented using DSL and Processor API, see ClickstreamJoinExample.
- Processor API version is up to 10 times more efficient than DSL version.
- Examples are configured with Embedded Kafka and does not require any additional setup.
- Implemented with Kafka 1.0
Missing Features
- Tests
- Closing WindowStoreIterator (it is not feasible with javaIt.asScala converter)