Package com.bakdata.kafka.producer

Class ExecutableProducerApp<T extends ProducerApp>

java.lang.Object

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

Type Parameters:

T - type of ProducerApp

All Implemented Interfaces:

ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>, AutoCloseable

public class ExecutableProducerApp<T extends ProducerApp>
extends Object
implements ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>

A ProducerApp with a corresponding ProducerTopicConfig and Kafka configuration

Method Summary

Modifier and Type	Method	Description
void	close()
ProducerCleanUpRunner	createCleanUpRunner()	Create ProducerCleanUpRunner in order to clean application
ProducerRunner	createRunner()	Create ProducerRunner in order to run application
ProducerRunner	createRunner(ProducerExecutionOptions options)	Create Runner in order to run application
T	getApp()
@NonNull Map<String,Object>	getKafkaProperties()
@NonNull ProducerTopicConfig	getTopics()

Methods inherited from class java.lang.Object

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

Method Details

createCleanUpRunner

public ProducerCleanUpRunner createCleanUpRunner()

Create ProducerCleanUpRunner in order to clean application

Specified by:

createCleanUpRunner in interface ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>

Returns:

ProducerCleanUpRunner

createRunner

public ProducerRunner createRunner()

Create ProducerRunner in order to run application

Specified by:

createRunner in interface ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>

Returns:

ProducerRunner

createRunner

public ProducerRunner createRunner(ProducerExecutionOptions options)

Description copied from interface: ExecutableApp

Create Runner in order to run application

Specified by:

createRunner in interface ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>

Parameters:

options - options for creating runner

Returns:

Runner

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ExecutableApp<ProducerRunner,ProducerCleanUpRunner,ProducerExecutionOptions>

getTopics

@NonNull
public @NonNull ProducerTopicConfig getTopics()

getKafkaProperties

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

getApp

@NonNull
public T getApp()