Package com.bakdata.kafka.streams

Interface LargeMessageStreamsApp

All Superinterfaces:

App<StreamsTopicConfig,StreamsCleanUpConfiguration>, AutoCloseable, StreamsApp

public interface LargeMessageStreamsApp
extends StreamsApp

StreamsApp that automatically removes files associated with LargeMessageSerde

Method Summary

Modifier and Type	Method	Description
default StreamsCleanUpConfiguration	setupCleanUp(AppConfiguration<StreamsTopicConfig> configuration)	Configure clean up behavior

Methods inherited from interface com.bakdata.kafka.App

close, createKafkaProperties, setup

Methods inherited from interface com.bakdata.kafka.streams.StreamsApp

buildTopology, defaultSerializationConfig, getUniqueAppId

Method Details

setupCleanUp

default StreamsCleanUpConfiguration setupCleanUp(AppConfiguration<StreamsTopicConfig> configuration)

Description copied from interface: App

Configure clean up behavior

Specified by:

setupCleanUp in interface App<StreamsTopicConfig,StreamsCleanUpConfiguration>

Specified by:

setupCleanUp in interface StreamsApp

Parameters:

configuration - provides all runtime application configurations

Returns:

StreamsCleanUpConfiguration

See Also:

• StreamsCleanUpRunner