Package com.bakdata.kafka.consumer

Class ConsumerCleanUpRunner

java.lang.Object

com.bakdata.kafka.consumer.ConsumerCleanUpRunner

All Implemented Interfaces:

CleanUpRunner, AutoCloseable

public final class ConsumerCleanUpRunner
extends Object
implements CleanUpRunner

Clean up all topics specified by a ConsumerTopicConfig

Method Summary

Modifier and Type	Method	Description
void	clean()	Clean all resources associated with an application
void	close()
static ConsumerCleanUpRunner	create(@NonNull ConsumerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull String groupId)	Create a new ConsumerCleanUpRunner with default ConsumerCleanUpConfiguration
static ConsumerCleanUpRunner	create(@NonNull ConsumerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull String groupId, @NonNull ConsumerCleanUpConfiguration configuration)	Create a new ConsumerCleanUpRunner
void	reset()	Reset your Consumer app by resetting consumer group offsets

Methods inherited from class java.lang.Object

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

Method Details

create

public static ConsumerCleanUpRunner create(@NonNull
 @NonNull ConsumerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties,
 @NonNull
 @NonNull String groupId)

Create a new ConsumerCleanUpRunner with default ConsumerCleanUpConfiguration

Parameters:

topics - topic configuration

kafkaProperties - configuration to connect to Kafka admin tools

groupId - consumer group id to clean up

Returns:

ConsumerCleanUpRunner

create

public static ConsumerCleanUpRunner create(@NonNull
 @NonNull ConsumerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties,
 @NonNull
 @NonNull String groupId,
 @NonNull
 @NonNull ConsumerCleanUpConfiguration configuration)

Create a new ConsumerCleanUpRunner

Parameters:

topics - topic configuration

kafkaProperties - configuration to connect to Kafka admin tools

groupId - consumer group id to clean up

configuration - configuration for hooks that are called when running clean()

Returns:

ConsumerCleanUpRunner

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CleanUpRunner

clean

public void clean()

Description copied from interface: CleanUpRunner

Clean all resources associated with an application

Specified by:

clean in interface CleanUpRunner

reset

public void reset()

Reset your Consumer app by resetting consumer group offsets