| StreamApp
StreamApp is a generic method for specifying the steps involved in building and running a KStream app that enables:
Defining some initial configuration that is applicable to the entire build process
Specifying the stream topology for the application in an arbitrary sequence of steps
Specifying which topics are needed to define te topology
Specifying topic configuration information in a flexible way
Collating the list of required topics, and providing and overriding configuration information for their creation
Providing a flexible configuration mechanism for setting Kafka properties
Creating the missing topics prior to running the stream
Running the stream application
Handling and cleanup / freeing of resources post termination of the stream
It is a functional abstraction on top of the Kafka Stream builder DSL that delays the execution of the stream build steps and allows for decorating the process with extra information.
|