Package com.bakdata.kafka.producer

Class ProducerCleanUpConfiguration

java.lang.Object

com.bakdata.kafka.producer.ProducerCleanUpConfiguration

All Implemented Interfaces:

HasCleanHook<ProducerCleanUpConfiguration>, HasTopicHooks<ProducerCleanUpConfiguration>, AutoCloseable

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

Provides configuration options for ProducerCleanUpRunner

Nested Class Summary

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

HasTopicHooks.TopicHook

Constructor Summary

Constructors

Constructor	Description
ProducerCleanUpConfiguration()

Method Summary

Modifier and Type	Method	Description
void	close()
ProducerCleanUpConfiguration	registerCleanHook(Runnable hook)	Register an action that is executed after ProducerCleanUpRunner.clean() has finished
ProducerCleanUpConfiguration	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

ProducerCleanUpConfiguration

public ProducerCleanUpConfiguration()

Method Details

registerTopicHook

public ProducerCleanUpConfiguration 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<ProducerCleanUpConfiguration>

Parameters:

hook - Action to run. Topic is passed as parameter

Returns:

self for chaining

registerCleanHook

public ProducerCleanUpConfiguration registerCleanHook(Runnable hook)

Register an action that is executed after ProducerCleanUpRunner.clean() has finished

Specified by:

registerCleanHook in interface HasCleanHook<ProducerCleanUpConfiguration>

Parameters:

hook - factory to create hook from

Returns:

self for chaining

close

public void close()

Specified by:

close in interface AutoCloseable