Package com.bakdata.kafka.streams

Class StreamsCleanUpConfiguration

java.lang.Object

com.bakdata.kafka.streams.StreamsCleanUpConfiguration

All Implemented Interfaces:

HasCleanHook<StreamsCleanUpConfiguration>, HasTopicHooks<StreamsCleanUpConfiguration>, AutoCloseable

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

Provides configuration options for StreamsCleanUpRunner

Nested Class Summary

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

HasTopicHooks.TopicHook

Constructor Summary

Constructors

Constructor	Description
StreamsCleanUpConfiguration()

Method Summary

Modifier and Type	Method	Description
void	close()
StreamsCleanUpConfiguration	registerCleanHook(Runnable hook)	Register a hook that is executed after StreamsCleanUpRunner.clean() has finished
StreamsCleanUpConfiguration	registerResetHook(Runnable hook)	Register a hook that is executed after StreamsCleanUpRunner.reset() has finished
StreamsCleanUpConfiguration	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

StreamsCleanUpConfiguration

public StreamsCleanUpConfiguration()

Method Details

registerTopicHook

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

Parameters:

hook - Action to run. Topic is passed as parameter

Returns:

self for chaining

registerCleanHook

public StreamsCleanUpConfiguration registerCleanHook(Runnable hook)

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

Specified by:

registerCleanHook in interface HasCleanHook<StreamsCleanUpConfiguration>

Parameters:

hook - factory to create hook from

Returns:

self for chaining

registerResetHook

public StreamsCleanUpConfiguration registerResetHook(Runnable hook)

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

Parameters:

hook - factory to create hook from

Returns:

self for chaining

close

public void close()

Specified by:

close in interface AutoCloseable