Package com.bakdata.kafka.producer

Class ProducerCleanUpRunner

java.lang.Object

com.bakdata.kafka.producer.ProducerCleanUpRunner

All Implemented Interfaces:

CleanUpRunner, AutoCloseable

public final class ProducerCleanUpRunner
extends Object
implements CleanUpRunner

Delete all output topics specified by a ProducerTopicConfig

Method Summary

Modifier and Type	Method	Description
void	clean()	Delete all output topics
void	close()
static ProducerCleanUpRunner	create(@NonNull ProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties)	Create a new ProducerCleanUpRunner with default ProducerCleanUpConfiguration
static ProducerCleanUpRunner	create(@NonNull ProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties, @NonNull ProducerCleanUpConfiguration configuration)	Create a new ProducerCleanUpRunner

Methods inherited from class java.lang.Object

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

Method Details

create

public static ProducerCleanUpRunner create(@NonNull
 @NonNull ProducerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties)

Create a new ProducerCleanUpRunner with default ProducerCleanUpConfiguration

Parameters:

topics - topic configuration to infer output topics that require cleaning

kafkaProperties - configuration to connect to Kafka admin tools

Returns:

ProducerCleanUpRunner

create

public static ProducerCleanUpRunner create(@NonNull
 @NonNull ProducerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties,
 @NonNull
 @NonNull ProducerCleanUpConfiguration configuration)

Create a new ProducerCleanUpRunner

Parameters:

topics - topic configuration to infer output topics that require cleaning

kafkaProperties - configuration to connect to Kafka admin tools

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

Returns:

ProducerCleanUpRunner

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CleanUpRunner

clean

public void clean()

Delete all output topics

Specified by:

clean in interface CleanUpRunner