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

Delete all output topics specified by a ConsumerProducerTopicConfig

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 ConsumerCleanUpConfiguration
static ConsumerProducerCleanUpRunner	create(@NonNull ConsumerProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull String groupId, @NonNull StreamsCleanUpConfiguration 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 ConsumerCleanUpConfiguration

Parameters:

topics - topic configuration

kafkaProperties - configuration to connect to Kafka admin tools

Returns:

ConsumerProducerCleanUpRunner

create

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

Create a new ConsumerProducerCleanUpRunner

Parameters:

topics - topic configuration

kafkaProperties - configuration to connect to Kafka admin tools

groupId - group id of the consumer

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