Package com.bakdata.kafka.producer

Interface ProducerApp

All Superinterfaces:

App<ProducerTopicConfig,ProducerCleanUpConfiguration>, AutoCloseable

All Known Subinterfaces:

LargeMessageProducerApp

public interface ProducerApp
extends App<ProducerTopicConfig,ProducerCleanUpConfiguration>

Application that defines how to produce messages to Kafka and necessary configurations

Method Summary

Modifier and Type	Method	Description
ProducerRunnable	buildRunnable(ProducerBuilder builder)	Create a runnable that produces Kafka messages
SerializerConfig	defaultSerializationConfig()	Configure default serialization behavior
default ProducerCleanUpConfiguration	setupCleanUp(AppConfiguration<ProducerTopicConfig> configuration)	Configure clean up behavior

Methods inherited from interface com.bakdata.kafka.App

close, createKafkaProperties, setup

Method Details

buildRunnable

ProducerRunnable buildRunnable(ProducerBuilder builder)

Create a runnable that produces Kafka messages

Parameters:

builder - provides all runtime application configurations

Returns:

ProducerRunnable

setupCleanUp

default ProducerCleanUpConfiguration setupCleanUp(AppConfiguration<ProducerTopicConfig> configuration)

Description copied from interface: App

Configure clean up behavior

Specified by:

setupCleanUp in interface App<ProducerTopicConfig,ProducerCleanUpConfiguration>

Parameters:

configuration - provides all runtime application configurations

Returns:

ProducerCleanUpConfiguration

See Also:

• ProducerCleanUpRunner

defaultSerializationConfig

SerializerConfig defaultSerializationConfig()

Description copied from interface: App

Configure default serialization behavior

Specified by:

defaultSerializationConfig in interface App<ProducerTopicConfig,ProducerCleanUpConfiguration>

Returns:

SerializationConfig