Package com.bakdata.kafka

Class LargeMessageAppUtils

java.lang.Object

com.bakdata.kafka.LargeMessageAppUtils

public final class LargeMessageAppUtils
extends Object

Utility class that provides helpers for cleaning LargeMessageSerde artifacts

Method Summary

Modifier and Type	Method	Description
static HasTopicHooks.TopicHook	createTopicHook(AppConfiguration<?> configuration)	Create a hook that cleans up LargeMessage files associated with a topic.
static HasTopicHooks.TopicHook	createTopicHook(Map<String,Object> kafkaProperties)	Create a hook that cleans up LargeMessage files associated with a topic.
static <T> T	registerTopicHook(HasTopicHooks<T> cleanUpConfiguration, AppConfiguration<?> configuration)	Register a hook that cleans up LargeMessage files associated with a topic

Methods inherited from class java.lang.Object

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

Method Details

createTopicHook

public static HasTopicHooks.TopicHook createTopicHook(Map<String,Object> kafkaProperties)

Create a hook that cleans up LargeMessage files associated with a topic. It is expected that all necessary properties to create a AbstractLargeMessageConfig are part of kafkaProperties.

Parameters:

kafkaProperties - Kafka properties to create hook from

Returns:

hook that cleans up LargeMessage files associated with a topic

See Also:

• HasTopicHooks.registerTopicHook(TopicHook)

createTopicHook

public static HasTopicHooks.TopicHook createTopicHook(AppConfiguration<?> configuration)

Create a hook that cleans up LargeMessage files associated with a topic. It is expected that all necessary properties to create a AbstractLargeMessageConfig are part of AppConfiguration.getKafkaProperties().

Parameters:

configuration - Configuration to create hook from

Returns:

hook that cleans up LargeMessage files associated with a topic

See Also:

• createTopicHook(Map)

registerTopicHook

public static <T> T registerTopicHook(HasTopicHooks<T> cleanUpConfiguration,
 AppConfiguration<?> configuration)

Register a hook that cleans up LargeMessage files associated with a topic

Type Parameters:

T - type of configuration

Parameters:

cleanUpConfiguration - Configuration to register hook on

configuration - Configuration to create hook from

Returns:

Configuration with registered topic hook

See Also:

• createTopicHook(AppConfiguration)