Package org.springframework.kafka.config

Class CompositeKafkaStreamsCustomizer

java.lang.Object

org.springframework.kafka.config.CompositeKafkaStreamsCustomizer

All Implemented Interfaces:

KafkaStreamsCustomizer

public class CompositeKafkaStreamsCustomizer
extends Object
implements KafkaStreamsCustomizer

Composite KafkaStreamsCustomizer customizes KafkaStreams by delegating to a list of provided KafkaStreamsCustomizer.

Since:

2.1.5

Author:

Nurettin Yilmaz, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
CompositeKafkaStreamsCustomizer()
CompositeKafkaStreamsCustomizer(List<KafkaStreamsCustomizer> kafkaStreamsCustomizers)

Method Summary

Modifier and Type	Method	Description
void	addKafkaStreamsCustomizers(List<KafkaStreamsCustomizer> customizers)
void	customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)	Customize the instance of KafkaStreams after StreamsBuilderFactoryBean has applied its default configurations.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.kafka.config.KafkaStreamsCustomizer

initKafkaStreams

Constructor Details

CompositeKafkaStreamsCustomizer

public CompositeKafkaStreamsCustomizer()

CompositeKafkaStreamsCustomizer

public CompositeKafkaStreamsCustomizer(List<KafkaStreamsCustomizer> kafkaStreamsCustomizers)

Method Details

customize

public void customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)

Description copied from interface: KafkaStreamsCustomizer

Customize the instance of KafkaStreams after StreamsBuilderFactoryBean has applied its default configurations.

Specified by:

customize in interface KafkaStreamsCustomizer

Parameters:

kafkaStreams - the instantiated Kafka Streams instance

addKafkaStreamsCustomizers

public void addKafkaStreamsCustomizers(List<KafkaStreamsCustomizer> customizers)