Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerCleanUpRunner

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerCleanUpRunner

All Implemented Interfaces:

CleanUpRunner, AutoCloseable

public final class ConsumerProducerCleanUpRunner
extends Object
implements CleanUpRunner

Runner to clean() or reset() a ConsumerProducerApp clean() deletes all output topics specified by a ConsumerProducerTopicConfig and the consumer group specified in the constructor. reset() resets the consumer group to the earliest offset. Both methods also run hooks registered in a ConsumerProducerCleanUpConfiguration.

Method Summary

Modifier and Type	Method	Description
void	clean()	Clean all resources associated with an application
void	close()
static ConsumerProducerCleanUpRunner	create(@NonNull ConsumerProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull String groupId)	Create a new ConsumerProducerCleanUpRunner with default ConsumerProducerCleanUpConfiguration
static ConsumerProducerCleanUpRunner	create(@NonNull ConsumerProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull String groupId, @NonNull ConsumerProducerCleanUpConfiguration configuration)	Create a new ConsumerProducerCleanUpRunner
void	reset()	Reset your ConsumerProducer 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 ConsumerProducerCleanUpRunner create(@NonNull
 @NonNull ConsumerProducerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties,
 @NonNull
 @NonNull String groupId)

Create a new ConsumerProducerCleanUpRunner with default ConsumerProducerCleanUpConfiguration

Parameters:

topics - topic configuration

kafkaProperties - configuration to connect to Kafka admin tools

groupId - consumer group id to clean up

Returns:

ConsumerProducerCleanUpRunner

create

public static ConsumerProducerCleanUpRunner create(@NonNull
 @NonNull ConsumerProducerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties,
 @NonNull
 @NonNull String groupId,
 @NonNull
 @NonNull ConsumerProducerCleanUpConfiguration configuration)

Create a new ConsumerProducerCleanUpRunner

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 during clean up and reset

Returns:

ConsumerProducerCleanUpRunner

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 ConsumerProducer app by resetting consumer group offsets