io.simplesource.saga.shared.app

Class StreamApp<I>

java.lang.Object

io.simplesource.saga.shared.app.StreamApp<I>

Type Parameters:

I - Input into

public class StreamApp<I>
extends Object

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. It is applied in this project wrapped in a thin layer by the ActionApp.

Constructor Summary

Constructors

Constructor and Description
StreamApp(I streamAppInput)

Method Summary

Modifier and Type	Method and Description
StreamBuildResult	build(PropertiesBuilder.BuildSteps properties)
void	run(PropertiesBuilder.BuildSteps properties) Run the SourcingApp with the given configuration steps
StreamApp<I>	withBuildStep(StreamBuildStep<I> buildStep)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamApp

public StreamApp(I streamAppInput)

Method Detail

withBuildStep

public final StreamApp<I> withBuildStep(StreamBuildStep<I> buildStep)

build

public StreamBuildResult build(PropertiesBuilder.BuildSteps properties)

run

public void run(PropertiesBuilder.BuildSteps properties)

Run the SourcingApp with the given configuration steps

Parameters:

properties - the app properties