Package com.bakdata.kafka.consumer

Interface ConsumerApp

All Superinterfaces:

App<ConsumerTopicConfig,ConsumerCleanUpConfiguration>, AutoCloseable

public interface ConsumerApp
extends App<ConsumerTopicConfig,ConsumerCleanUpConfiguration>

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

Method Summary

Modifier and Type	Method	Description
ConsumerRunnable	buildRunnable(ConsumerBuilder builder)	Create a runnable that consumes Kafka messages
DeserializerConfig	defaultSerializationConfig()	Configure default serialization behavior
default String	getUniqueGroupId(ConsumerAppConfiguration configuration)	This must be set to a unique value that identifies the consumer group this consumer belongs to.
default ConsumerCleanUpConfiguration	setupCleanUp(AppConfiguration<ConsumerTopicConfig> configuration)	Configure clean up behavior

Methods inherited from interface com.bakdata.kafka.App

close, createKafkaProperties, setup

Method Details

buildRunnable

ConsumerRunnable buildRunnable(ConsumerBuilder builder)

Create a runnable that consumes Kafka messages

Parameters:

builder - provides all runtime application configurations

Returns:

ConsumerRunnable

setupCleanUp

default ConsumerCleanUpConfiguration setupCleanUp(AppConfiguration<ConsumerTopicConfig> configuration)

Description copied from interface: App

Configure clean up behavior

Specified by:

setupCleanUp in interface App<ConsumerTopicConfig,ConsumerCleanUpConfiguration>

Parameters:

configuration - provides all runtime application configurations

Returns:

ConsumerCleanUpConfiguration

See Also:

• ConsumerCleanUpRunner

getUniqueGroupId

default String getUniqueGroupId(ConsumerAppConfiguration configuration)

This must be set to a unique value that identifies the consumer group this consumer belongs to. Could be set to: className-inputTopic.

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

Parameters:

configuration - provides runtime configuration

Returns:

unique group identifier

defaultSerializationConfig

DeserializerConfig defaultSerializationConfig()

Description copied from interface: App

Configure default serialization behavior

Specified by:

defaultSerializationConfig in interface App<ConsumerTopicConfig,ConsumerCleanUpConfiguration>

Returns:

SerializationConfig