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 -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()registerCleanHook(Runnable hook) Register a hook that is executed afterConsumerProducerCleanUpRunner.clean()has finishedregisterResetHook(Runnable hook) Register a hook that is executed afterConsumerProducerCleanUpRunner.reset()has finishedRegister a hook that is executed whenever a topic has been deleted by the cleanup runner.
-
Constructor Details
-
ConsumerProducerCleanUpConfiguration
public ConsumerProducerCleanUpConfiguration()
-
-
Method Details
-
registerTopicHook
Register a hook that is executed whenever a topic has been deleted by the cleanup runner.- Specified by:
registerTopicHookin interfaceHasTopicHooks<ConsumerProducerCleanUpConfiguration>- Parameters:
hook- the hook to execute- Returns:
- self for chaining
-
registerCleanHook
Register a hook that is executed afterConsumerProducerCleanUpRunner.clean()has finished- Specified by:
registerCleanHookin interfaceHasCleanHook<ConsumerProducerCleanUpConfiguration>- Parameters:
hook- the runnable to execute- Returns:
- self for chaining
-
registerResetHook
Register a hook that is executed afterConsumerProducerCleanUpRunner.reset()has finished- Parameters:
hook- the runnable to execute- Returns:
- self for chaining
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-