Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerCleanUpConfiguration

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerCleanUpConfiguration

All Implemented Interfaces:

HasCleanHook<ConsumerProducerCleanUpConfiguration>, HasTopicHooks<ConsumerProducerCleanUpConfiguration>, AutoCloseable

public class ConsumerProducerCleanUpConfiguration
extends Object
implements HasTopicHooks<ConsumerProducerCleanUpConfiguration>, HasCleanHook<ConsumerProducerCleanUpConfiguration>, AutoCloseable

Provides configuration options for ConsumerProducerCleanUpRunner

Nested Class Summary

Nested classes/interfaces inherited from interface com.bakdata.kafka.HasTopicHooks

HasTopicHooks.TopicHook

Constructor Summary

Constructors

Constructor	Description
ConsumerProducerCleanUpConfiguration()

Method Summary

Modifier and Type	Method	Description
void	close()
ConsumerProducerCleanUpConfiguration	registerCleanHook(Runnable hook)	Register a hook that is executed after ConsumerProducerCleanUpRunner.clean() has finished
ConsumerProducerCleanUpConfiguration	registerResetHook(Runnable hook)	Register a hook that is executed after ConsumerProducerCleanUpRunner.reset() has finished
ConsumerProducerCleanUpConfiguration	registerTopicHook(HasTopicHooks.TopicHook hook)	Register a hook that is executed whenever a topic has been deleted by the cleanup runner.

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerProducerCleanUpConfiguration

public ConsumerProducerCleanUpConfiguration()

Method Details

registerTopicHook

public ConsumerProducerCleanUpConfiguration registerTopicHook(HasTopicHooks.TopicHook hook)

Register a hook that is executed whenever a topic has been deleted by the cleanup runner.

Specified by:

registerTopicHook in interface HasTopicHooks<ConsumerProducerCleanUpConfiguration>

Parameters:

hook - the hook to execute

Returns:

self for chaining

registerCleanHook

public ConsumerProducerCleanUpConfiguration registerCleanHook(Runnable hook)

Register a hook that is executed after ConsumerProducerCleanUpRunner.clean() has finished

Specified by:

registerCleanHook in interface HasCleanHook<ConsumerProducerCleanUpConfiguration>

Parameters:

hook - the runnable to execute

Returns:

self for chaining

registerResetHook

public ConsumerProducerCleanUpConfiguration registerResetHook(Runnable hook)

Register a hook that is executed after ConsumerProducerCleanUpRunner.reset() has finished

Parameters:

hook - the runnable to execute

Returns:

self for chaining

close

public void close()

Specified by:

close in interface AutoCloseable