Package com.bakdata.kafka.producer

Interface LargeMessageProducerApp

All Superinterfaces:

App<ProducerTopicConfig,ProducerCleanUpConfiguration>, AutoCloseable, ProducerApp

public interface LargeMessageProducerApp
extends ProducerApp

ProducerApp that automatically removes files associated with LargeMessageSerializer

Method Summary

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

Methods inherited from interface com.bakdata.kafka.App

close, createKafkaProperties, setup

Methods inherited from interface com.bakdata.kafka.producer.ProducerApp

buildRunnable, defaultSerializationConfig

Method Details

setupCleanUp

default ProducerCleanUpConfiguration setupCleanUp(AppConfiguration<ProducerTopicConfig> configuration)

Description copied from interface: App

Configure clean up behavior

Specified by:

setupCleanUp in interface App<ProducerTopicConfig,ProducerCleanUpConfiguration>

Specified by:

setupCleanUp in interface ProducerApp

Parameters:

configuration - provides all runtime application configurations

Returns:

ProducerCleanUpConfiguration

See Also:

• ProducerCleanUpRunner