Package org.springframework.kafka.config

Class CompositeKafkaStreamsCustomizer

java.lang.Object

org.springframework.kafka.config.CompositeKafkaStreamsCustomizer

All Implemented Interfaces:

KafkaStreamsCustomizer

public class CompositeKafkaStreamsCustomizer
extends java.lang.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(java.util.List<KafkaStreamsCustomizer> kafkaStreamsCustomizers)

Method Summary

Modifier and Type	Method	Description
void	addKafkaStreamsCustomizers(java.util.List<KafkaStreamsCustomizer> customizers)
void	customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeKafkaStreamsCustomizer

public CompositeKafkaStreamsCustomizer()

CompositeKafkaStreamsCustomizer

public CompositeKafkaStreamsCustomizer(java.util.List<KafkaStreamsCustomizer> kafkaStreamsCustomizers)

Method Detail

customize

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

Specified by:

customize in interface KafkaStreamsCustomizer

addKafkaStreamsCustomizers

public void addKafkaStreamsCustomizers(java.util.List<KafkaStreamsCustomizer> customizers)