Package org.springframework.kafka.config

Interface KafkaStreamsCustomizer

All Known Implementing Classes:

CompositeKafkaStreamsCustomizer

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface KafkaStreamsCustomizer

Callback interface that can be used to configure KafkaStreams directly.

Since:

2.1.5

Author:

Nurettin Yilmaz, Almog Gavra

See Also:

• StreamsBuilderFactoryBean

Method Summary

Modifier and Type	Method	Description
void	customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)	Customize the instance of KafkaStreams after StreamsBuilderFactoryBean has applied its default configurations.
default org.apache.kafka.streams.KafkaStreams	initKafkaStreams(org.apache.kafka.streams.Topology topology, Properties properties, org.apache.kafka.streams.KafkaClientSupplier clientSupplier)	Customize the instantiation of the KafkaStreams instance.

Method Details

initKafkaStreams

default org.apache.kafka.streams.KafkaStreams initKafkaStreams(org.apache.kafka.streams.Topology topology,
 Properties properties,
 org.apache.kafka.streams.KafkaClientSupplier clientSupplier)

Customize the instantiation of the KafkaStreams instance. This happens before the modifications made by StreamsBuilderFactoryBean.

Parameters:

topology - the full topology

properties - the configuration properties

clientSupplier - the client supplier

Returns:

a new instance of KafkaStreams

Since:

3.3.0

customize

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

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

Parameters:

kafkaStreams - the instantiated Kafka Streams instance