Package com.bakdata.kafka.consumerproducer

Class ExecutableConsumerProducerApp<T extends ConsumerProducerApp>

java.lang.Object

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

Type Parameters:

T - type of ConsumerProducerApp

All Implemented Interfaces:

ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>, AutoCloseable

public class ExecutableConsumerProducerApp<T extends ConsumerProducerApp>
extends Object
implements ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>

A ConsumerProducerApp with a corresponding ConsumerProducerTopicConfig and Kafka configuration

Method Summary

Modifier and Type	Method	Description
void	close()
ConsumerProducerCleanUpRunner	createCleanUpRunner()	Create ConsumerProducerCleanUpRunner in order to clean application
ConsumerProducerRunner	createRunner()	Create ConsumerProducerRunner in order to run application
ConsumerProducerRunner	createRunner(ConsumerProducerExecutionOptions options)	Create Runner in order to run application
T	getApp()
org.apache.kafka.clients.consumer.ConsumerConfig	getConsumerConfig()
@NonNull Map<String,Object>	getConsumerProperties()
@NonNull String	getGroupId()
org.apache.kafka.clients.producer.ProducerConfig	getProducerConfig()
@NonNull Map<String,Object>	getProducerProperties()
@NonNull ConsumerProducerTopicConfig	getTopics()

Methods inherited from class java.lang.Object

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

Method Details

createCleanUpRunner

public ConsumerProducerCleanUpRunner createCleanUpRunner()

Create ConsumerProducerCleanUpRunner in order to clean application

Specified by:

createCleanUpRunner in interface ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>

Returns:

ConsumerProducerCleanUpRunner

createRunner

public ConsumerProducerRunner createRunner()

Create ConsumerProducerRunner in order to run application

Specified by:

createRunner in interface ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>

Returns:

ConsumerProducerRunner

createRunner

public ConsumerProducerRunner createRunner(ConsumerProducerExecutionOptions options)

Description copied from interface: ExecutableApp

Create Runner in order to run application

Specified by:

createRunner in interface ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>

Parameters:

options - options for creating runner

Returns:

Runner

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ExecutableApp<ConsumerProducerRunner,ConsumerProducerCleanUpRunner,ConsumerProducerExecutionOptions>

getConsumerConfig

public org.apache.kafka.clients.consumer.ConsumerConfig getConsumerConfig()

getProducerConfig

public org.apache.kafka.clients.producer.ProducerConfig getProducerConfig()

getTopics

@NonNull
public @NonNull ConsumerProducerTopicConfig getTopics()

getProducerProperties

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

getConsumerProperties

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

getApp

@NonNull
public T getApp()

getGroupId

@NonNull
public @NonNull String getGroupId()