Package com.bakdata.kafka.consumer

Class SimpleKafkaConsumerApplication<T extends ConsumerApp>

java.lang.Object

com.bakdata.kafka.KafkaApplication<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions,ExecutableConsumerApp<T>,ConfiguredConsumerApp<T>,ConsumerTopicConfig,T,ConsumerAppConfiguration>

com.bakdata.kafka.consumer.KafkaConsumerApplication<T>

com.bakdata.kafka.consumer.SimpleKafkaConsumerApplication<T>

Type Parameters:

T - type of ConsumerApp created by this application

All Implemented Interfaces:

AutoCloseable, Runnable

public final class SimpleKafkaConsumerApplication<T extends ConsumerApp>
extends KafkaConsumerApplication<T>

KafkaConsumerApplication 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
SimpleKafkaConsumerApplication(@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.consumer.KafkaConsumerApplication

clean, createConfiguration, createConfiguredApp, createExecutionOptions, createTopicConfig, getConsumerOptions, getGroupId, getInputOptions, getInputPattern, getInputTopics, getLabeledInputPatterns, getLabeledInputTopics, getPollTimeout, isVolatileGroupInstanceId, onConsumerStart, reset, setConsumerOptions, setGroupId, setInputOptions, setInputPattern, setInputTopics, setLabeledInputPatterns, setLabeledInputTopics, setPollTimeout, 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

SimpleKafkaConsumerApplication

public SimpleKafkaConsumerApplication(@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<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions,ExecutableConsumerApp<T extends ConsumerApp>,ConfiguredConsumerApp<T extends ConsumerApp>,ConsumerTopicConfig,T extends ConsumerApp,ConsumerAppConfiguration>

Returns:

app