public class CompositeKafkaStreamsInfrastructureCustomizer extends java.lang.Object implements KafkaStreamsInfrastructureCustomizer
KafkaStreamsInfrastructureCustomizer customizes KafkaStreams
by delegating to a list of provided KafkaStreamsInfrastructureCustomizer.| Constructor and Description |
|---|
CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer... customizers)
Construct an instance with the provided customizers.
|
| Modifier and Type | Method and 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.
|
public CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer... customizers)
customizers - the customizers;public void addKafkaStreamsCustomizers(KafkaStreamsInfrastructureCustomizer... customizers)
customizers - the customizers.public void configureBuilder(org.apache.kafka.streams.StreamsBuilder builder)
KafkaStreamsInfrastructureCustomizerconfigureBuilder in interface KafkaStreamsInfrastructureCustomizerbuilder - the builder.public void configureTopology(org.apache.kafka.streams.Topology topology)
KafkaStreamsInfrastructureCustomizerconfigureTopology in interface KafkaStreamsInfrastructureCustomizertopology - the topology