Package com.bakdata.kafka.streams

Class ExecutableStreamsApp<T extends StreamsApp>

java.lang.Object

com.bakdata.kafka.streams.ExecutableStreamsApp<T>

Type Parameters:

T - type of StreamsApp

All Implemented Interfaces:

ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>, AutoCloseable

public class ExecutableStreamsApp<T extends StreamsApp>
extends Object
implements ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>

A StreamsApp with a corresponding Topology and StreamsConfig

Method Summary

Modifier and Type	Method	Description
void	close()
StreamsCleanUpRunner	createCleanUpRunner()	Create StreamsCleanUpRunner in order to clean application
StreamsRunner	createRunner()	Create StreamsRunner in order to run application with default StreamsExecutionOptions
StreamsRunner	createRunner(StreamsExecutionOptions executionOptions)	Create StreamsRunner in order to run application
T	getApp()
org.apache.kafka.streams.StreamsConfig	getConfig()
@NonNull Map<String,Object>	getKafkaProperties()
@NonNull StreamsTopicConfig	getTopics()
@NonNull org.apache.kafka.streams.Topology	getTopology()

Methods inherited from class java.lang.Object

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

Method Details

createCleanUpRunner

public StreamsCleanUpRunner createCleanUpRunner()

Create StreamsCleanUpRunner in order to clean application

Specified by:

createCleanUpRunner in interface ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>

Returns:

StreamsCleanUpRunner

createRunner

public StreamsRunner createRunner()

Create StreamsRunner in order to run application with default StreamsExecutionOptions

Specified by:

createRunner in interface ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>

Returns:

StreamsRunner

See Also:

• StreamsRunner(Topology, StreamsConfig)

createRunner

public StreamsRunner createRunner(StreamsExecutionOptions executionOptions)

Create StreamsRunner in order to run application

Specified by:

createRunner in interface ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>

Parameters:

executionOptions - options for running Kafka Streams application

Returns:

StreamsRunner

See Also:

• StreamsRunner(Topology, StreamsConfig, StreamsExecutionOptions)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ExecutableApp<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions>

getConfig

public org.apache.kafka.streams.StreamsConfig getConfig()

getTopology

@NonNull
public @NonNull org.apache.kafka.streams.Topology getTopology()

getKafkaProperties

@NonNull
public @NonNull Map<String,Object> getKafkaProperties()

getApp

@NonNull
public T getApp()

getTopics

@NonNull
public @NonNull StreamsTopicConfig getTopics()