Package com.bakdata.kafka.consumer

Class ExecutableConsumerApp<T extends ConsumerApp>

java.lang.Object

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

Type Parameters:

T - type of ConsumerApp

All Implemented Interfaces:

ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>, AutoCloseable

public class ExecutableConsumerApp<T extends ConsumerApp>
extends Object
implements ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>

A ConsumerApp with a corresponding ConsumerTopicConfig and Kafka configuration

Method Summary

Modifier and Type	Method	Description
void	close()
ConsumerCleanUpRunner	createCleanUpRunner()	Create ConsumerCleanUpRunner in order to clean application
ConsumerRunner	createRunner()	Create ConsumerRunner in order to run application
ConsumerRunner	createRunner(ConsumerExecutionOptions options)	Create Runner in order to run application
T	getApp()
org.apache.kafka.clients.consumer.ConsumerConfig	getConfig()
@NonNull String	getGroupId()
@NonNull Map<String,Object>	getKafkaProperties()
@NonNull ConsumerTopicConfig	getTopics()

Methods inherited from class java.lang.Object

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

Method Details

createCleanUpRunner

public ConsumerCleanUpRunner createCleanUpRunner()

Create ConsumerCleanUpRunner in order to clean application

Specified by:

createCleanUpRunner in interface ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>

Returns:

ConsumerCleanUpRunner

createRunner

public ConsumerRunner createRunner()

Create ConsumerRunner in order to run application

Specified by:

createRunner in interface ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>

Returns:

ConsumerRunner

createRunner

public ConsumerRunner createRunner(ConsumerExecutionOptions options)

Description copied from interface: ExecutableApp

Create Runner in order to run application

Specified by:

createRunner in interface ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>

Parameters:

options - options for creating runner

Returns:

Runner

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ExecutableApp<ConsumerRunner,ConsumerCleanUpRunner,ConsumerExecutionOptions>

getConfig

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

getTopics

@NonNull
public @NonNull ConsumerTopicConfig getTopics()

getKafkaProperties

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

getGroupId

@NonNull
public @NonNull String getGroupId()

getApp

@NonNull
public T getApp()