Package com.bakdata.kafka.streams

Class SimpleKafkaStreamsApplication<T extends StreamsApp>

java.lang.Object

com.bakdata.kafka.KafkaApplication<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions,ExecutableStreamsApp<T>,ConfiguredStreamsApp<T>,StreamsTopicConfig,T,StreamsAppConfiguration>

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

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

Type Parameters:

T - type of StreamsApp created by this application

All Implemented Interfaces:

AutoCloseable, Runnable

public final class SimpleKafkaStreamsApplication<T extends StreamsApp>
extends KafkaStreamsApplication<T>

KafkaStreamsApplication without any additional configuration options.

Nested Class Summary

Nested classes/interfaces inherited from class com.bakdata.kafka.KafkaApplication

KafkaApplication.CleanableApp<CR extends CleanUpRunner>, KafkaApplication.RunnableApp<R extends Runner>

Constructor Summary

Constructors

Constructor	Description
SimpleKafkaStreamsApplication(@NonNull Supplier<T> appFactory)

Method Summary

Modifier and Type	Method	Description
T	createApp()	Create a new app that will be configured and executed according to this application.

Methods inherited from class com.bakdata.kafka.streams.KafkaStreamsApplication

clean, createConfiguration, createConfiguredApp, createExecutionOptions, createStateListener, createTopicConfig, createUncaughtExceptionHandler, getApplicationId, getErrorTopic, getInputPattern, getInputTopics, getLabeledInputPatterns, getLabeledInputTopics, isVolatileGroupInstanceId, onStreamsStart, prepareClean, reset, setApplicationId, setErrorTopic, setInputPattern, setInputTopics, setLabeledInputPatterns, setLabeledInputTopics, setVolatileGroupInstanceId, toString

Methods inherited from class com.bakdata.kafka.KafkaApplication

close, createCleanableApp, createConfiguredApp, createExecutableApp, createRunnableApp, getBootstrapServers, getKafkaConfig, getLabeledOutputTopics, getOutputTopic, getRuntimeConfiguration, getSchemaRegistryUrl, onApplicationStart, prepareRun, run, setBootstrapServers, setKafkaConfig, setLabeledOutputTopics, setOutputTopic, setSchemaRegistryUrl, startApplication, startApplicationWithoutExit, stop

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleKafkaStreamsApplication

public SimpleKafkaStreamsApplication(@NonNull
 @NonNull Supplier<T> appFactory)

Method Details

createApp

public T createApp()

Description copied from class: KafkaApplication

Create a new app that will be configured and executed according to this application.

Specified by:

createApp in class KafkaApplication<StreamsRunner,StreamsCleanUpRunner,StreamsExecutionOptions,ExecutableStreamsApp<T extends StreamsApp>,ConfiguredStreamsApp<T extends StreamsApp>,StreamsTopicConfig,T extends StreamsApp,StreamsAppConfiguration>

Returns:

app