Package com.bakdata.kafka.consumerproducer

Class SimpleKafkaConsumerProducerApplication<T extends ConsumerProducerApp>

java.lang.Object

com.bakdata.kafka.KafkaApplication<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions,ExecutableConsumerProducerApp<T>,ConfiguredConsumerProducerApp<T>,ConsumerProducerTopicConfig,T,ConsumerProducerAppConfiguration>

com.bakdata.kafka.consumerproducer.KafkaConsumerProducerApplication<T>

com.bakdata.kafka.consumerproducer.SimpleKafkaConsumerProducerApplication<T>

Type Parameters:

T - type of ConsumerProducerApp created by this application

All Implemented Interfaces:

AutoCloseable, Runnable

public final class SimpleKafkaConsumerProducerApplication<T extends ConsumerProducerApp>
extends KafkaConsumerProducerApplication<T>

KafkaConsumerProducerApplication 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
SimpleKafkaConsumerProducerApplication(@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.consumerproducer.KafkaConsumerProducerApplication

clean, createConfiguration, createConfiguredApp, createExecutionOptions, createTopicConfig, getConsumerOptions, getErrorOptions, getErrorTopic, getGroupId, getInputOptions, getInputPattern, getInputTopics, getLabeledInputPatterns, getLabeledInputTopics, getLabeledOutputTopics, getOutputOptions, getOutputTopic, isVolatileGroupInstanceId, reset, setConsumerOptions, setErrorOptions, setErrorTopic, setGroupId, setInputOptions, setInputPattern, setInputTopics, setLabeledInputPatterns, setLabeledInputTopics, setLabeledOutputTopics, setOutputOptions, setOutputTopic, setVolatileGroupInstanceId, toString

Methods inherited from class com.bakdata.kafka.KafkaApplication

close, createCleanableApp, createConfiguredApp, createExecutableApp, createRunnableApp, getBootstrapServers, getKafkaConfig, getRuntimeConfiguration, getSchemaRegistryUrl, onApplicationStart, prepareClean, prepareRun, run, setBootstrapServers, setKafkaConfig, setSchemaRegistryUrl, startApplication, startApplicationWithoutExit, stop

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleKafkaConsumerProducerApplication

public SimpleKafkaConsumerProducerApplication(@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<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions,ExecutableConsumerProducerApp<T extends ConsumerProducerApp>,ConfiguredConsumerProducerApp<T extends ConsumerProducerApp>,ConsumerProducerTopicConfig,T extends ConsumerProducerApp,ConsumerProducerAppConfiguration>

Returns:

app