Package com.bakdata.kafka.consumer

Class ConsumerCleanUpConfiguration

java.lang.Object

com.bakdata.kafka.consumer.ConsumerCleanUpConfiguration

All Implemented Interfaces:

HasCleanHook<ConsumerCleanUpConfiguration>

public class ConsumerCleanUpConfiguration
extends Object
implements HasCleanHook<ConsumerCleanUpConfiguration>

Provides configuration options for ConsumerCleanUpRunner

Constructor Summary

Constructors

Constructor	Description
ConsumerCleanUpConfiguration()

Method Summary

Modifier and Type	Method	Description
ConsumerCleanUpConfiguration	registerCleanHook(Runnable hook)	Register an action that is executed after ConsumerCleanUpRunner.clean() has finished
ConsumerCleanUpConfiguration	registerResetHook(Runnable hook)	Register a hook that is executed after ConsumerCleanUpRunner.reset() has finished

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerCleanUpConfiguration

public ConsumerCleanUpConfiguration()

Method Details

registerCleanHook

public ConsumerCleanUpConfiguration registerCleanHook(Runnable hook)

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

Specified by:

registerCleanHook in interface HasCleanHook<ConsumerCleanUpConfiguration>

Parameters:

hook - factory to create hook from

Returns:

self for chaining

registerResetHook

public ConsumerCleanUpConfiguration registerResetHook(Runnable hook)

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

Parameters:

hook - factory to create hook from

Returns:

self for chaining