example-kafkastreams icon indicating copy to clipboard operation
example-kafkastreams copied to clipboard

Kafka Streams DSL vs Processor API

Kafka Streams DSL vs Processor API

Build Status

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)

References