Package com.bakdata.kafka.consumerproducer

Interface ConsumerProducerApp

All Superinterfaces:

App<ConsumerProducerTopicConfig,StreamsCleanUpConfiguration>, AutoCloseable

public interface ConsumerProducerApp
extends App<ConsumerProducerTopicConfig,StreamsCleanUpConfiguration>

Application that defines how to produce or consume messages to and from Kafka and necessary configurations

Method Summary

Modifier and Type	Method	Description
ConsumerProducerRunnable	buildRunnable(ConsumerProducerBuilder builder)	Create a runnable that consumes and produces Kafka messages
SerializerDeserializerConfig	defaultSerializationConfig()	Configure default serialization behavior
default String	getUniqueAppId(ConsumerProducerAppConfiguration configuration)	This must be set to a unique value for every application interacting with your Kafka cluster to ensure internal state encapsulation.
default StreamsCleanUpConfiguration	setupCleanUp(AppConfiguration<ConsumerProducerTopicConfig> configuration)	Configure clean up behavior

Methods inherited from interface com.bakdata.kafka.App

close, createKafkaProperties, setup

Method Details

buildRunnable

ConsumerProducerRunnable buildRunnable(ConsumerProducerBuilder builder)

Create a runnable that consumes and produces Kafka messages

Parameters:

builder - provides all runtime application configurations

Returns:

ConsumerProducerRunnable

getUniqueAppId

default String getUniqueAppId(ConsumerProducerAppConfiguration configuration)

This must be set to a unique value for every application interacting with your Kafka cluster to ensure internal state encapsulation. Could be set to: className-outputTopic.

User may provide a unique group identifier via ConsumerProducerAppConfiguration.getUniqueAppId(). If that is the case, the returned group ID should match the provided one.

Parameters:

configuration - provides runtime configuration

Returns:

unique group identifier

setupCleanUp

default StreamsCleanUpConfiguration setupCleanUp(AppConfiguration<ConsumerProducerTopicConfig> configuration)

Description copied from interface: App

Configure clean up behavior

Specified by:

setupCleanUp in interface App<ConsumerProducerTopicConfig,StreamsCleanUpConfiguration>

Parameters:

configuration - provides all runtime application configurations

Returns:

StreamsCleanUpConfiguration

See Also:

• StreamsCleanUpRunner

defaultSerializationConfig

SerializerDeserializerConfig defaultSerializationConfig()

Description copied from interface: App

Configure default serialization behavior

Specified by:

defaultSerializationConfig in interface App<ConsumerProducerTopicConfig,StreamsCleanUpConfiguration>

Returns:

SerializationConfig