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)
KafkaStreamsInfrastructureCustomizer
configureBuilder
in interface KafkaStreamsInfrastructureCustomizer
builder
- the builder.public void configureTopology(org.apache.kafka.streams.Topology topology)
KafkaStreamsInfrastructureCustomizer
configureTopology
in interface KafkaStreamsInfrastructureCustomizer
topology
- the topology