Streams DSL — High-Level Stream Processing DSL
Kafka Streams offers Streams DSL with high-level data stream abstractions for streams, tables, state stores, topologies.
Streams DSL includes:
-
StreamsBuilder for defining a topology
-
KStream for working with record streams
-
KTable for working with changelog streams
-
GlobalKTable for working with global changelog streams
Streams DSL also includes the following for streaming aggregations and joins:
Streams DSL is designed for Java developers primarily, but also offers Scala API for Kafka Streams for Scala developers.