Package org.springframework.kafka.config

Class CompositeKafkaStreamsInfrastructureCustomizer

java.lang.Object

org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer

All Implemented Interfaces:

KafkaStreamsInfrastructureCustomizer

public class CompositeKafkaStreamsInfrastructureCustomizer
extends Object
implements KafkaStreamsInfrastructureCustomizer

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

Since:

2.4.1

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer... customizers)	Construct an instance with the provided customizers.

Method Summary

Modifier and Type	Method	Description
void	addKafkaStreamsCustomizers(KafkaStreamsInfrastructureCustomizer... customizers)	Add customizers.
void	configureBuilder(org.apache.kafka.streams.StreamsBuilder builder)	Configure the builder.
void	configureTopology(org.apache.kafka.streams.Topology topology)	Configure the topology.

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeKafkaStreamsInfrastructureCustomizer

public CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer... customizers)

Construct an instance with the provided customizers.

Parameters:

customizers - the customizers;

Method Details

addKafkaStreamsCustomizers

public void addKafkaStreamsCustomizers(KafkaStreamsInfrastructureCustomizer... customizers)

Add customizers.

Parameters:

customizers - the customizers.

configureBuilder

public void configureBuilder(org.apache.kafka.streams.StreamsBuilder builder)

Description copied from interface: KafkaStreamsInfrastructureCustomizer

Configure the builder.

Specified by:

configureBuilder in interface KafkaStreamsInfrastructureCustomizer

Parameters:

builder - the builder.

configureTopology

public void configureTopology(org.apache.kafka.streams.Topology topology)

Description copied from interface: KafkaStreamsInfrastructureCustomizer

Configure the topology.

Specified by:

configureTopology in interface KafkaStreamsInfrastructureCustomizer

Parameters:

topology - the topology