Package com.bakdata.kafka.producer

Class SimpleKafkaProducerApplication<T extends ProducerApp>

java.lang.Object

com.bakdata.kafka.KafkaApplication<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions,ExecutableProducerApp<T>,ConfiguredProducerApp<T>,ProducerTopicConfig,T,ProducerAppConfiguration>

com.bakdata.kafka.producer.KafkaProducerApplication<T>

com.bakdata.kafka.producer.SimpleKafkaProducerApplication<T>

Type Parameters:

T - type of ProducerApp created by this application

All Implemented Interfaces:

AutoCloseable, Runnable

public final class SimpleKafkaProducerApplication<T extends ProducerApp>
extends KafkaProducerApplication<T>

KafkaProducerApplication 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
SimpleKafkaProducerApplication(@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.producer.KafkaProducerApplication

clean, createConfiguration, createConfiguredApp, createExecutionOptions, createTopicConfig, toString

Methods inherited from class com.bakdata.kafka.KafkaApplication

close, createCleanableApp, createConfiguredApp, createExecutableApp, createRunnableApp, getBootstrapServers, getKafkaConfig, getLabeledOutputTopics, getOutputTopic, getRuntimeConfiguration, getSchemaRegistryUrl, onApplicationStart, prepareClean, 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

SimpleKafkaProducerApplication

public SimpleKafkaProducerApplication(@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<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions,ExecutableProducerApp<T extends ProducerApp>,ConfiguredProducerApp<T extends ProducerApp>,ProducerTopicConfig,T extends ProducerApp,ProducerAppConfiguration>

Returns:

app