| Interface | Description |
|---|---|
| ContainerCustomizer<K,V,C extends AbstractMessageListenerContainer<K,V>> |
Called by the container factory after the container is created and configured.
|
| KafkaListenerContainerFactory<C extends MessageListenerContainer> |
Factory for
MessageListenerContainers. |
| KafkaListenerEndpoint |
Model for a Kafka listener endpoint.
|
| KafkaStreamsCustomizer |
Callback interface that can be used to configure
KafkaStreams directly. |
| KafkaStreamsInfrastructureCustomizer |
A customizer for infrastructure components such as the
StreamsBuilder and
Topology. |
| StreamsBuilderFactoryBean.Listener |
Called whenever a
KafkaStreams is added or removed. |
| StreamsBuilderFactoryBeanCustomizer |
A customizer for the
StreamsBuilderFactoryBean that is implicitly created by
EnableKafkaStreams. |
| Class | Description |
|---|---|
| AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V> |
Base
KafkaListenerContainerFactory for Spring's base container implementation. |
| AbstractKafkaListenerEndpoint<K,V> |
Base model for a Kafka listener endpoint.
|
| CompositeKafkaStreamsCustomizer |
Composite
KafkaStreamsCustomizer customizes KafkaStreams by delegating
to a list of provided KafkaStreamsCustomizer. |
| CompositeKafkaStreamsInfrastructureCustomizer |
Composite
KafkaStreamsInfrastructureCustomizer customizes KafkaStreams
by delegating to a list of provided KafkaStreamsInfrastructureCustomizer. |
| ConcurrentKafkaListenerContainerFactory<K,V> |
A
KafkaListenerContainerFactory implementation to build a
ConcurrentMessageListenerContainer. |
| KafkaListenerConfigUtils |
Configuration constants for internal sharing across subpackages.
|
| KafkaListenerEndpointRegistrar |
Helper bean for registering
KafkaListenerEndpoint with
a KafkaListenerEndpointRegistry. |
| KafkaListenerEndpointRegistry |
Creates the necessary
MessageListenerContainer instances for the
registered endpoints. |
| KafkaStreamsConfiguration |
Wrapper for
StreamsBuilder properties. |
| MethodKafkaListenerEndpoint<K,V> |
A
KafkaListenerEndpoint providing the method to invoke to process
an incoming message for this endpoint. |
| MultiMethodKafkaListenerEndpoint<K,V> |
The
MethodKafkaListenerEndpoint extension for several POJO methods
based on the KafkaHandler. |
| StreamsBuilderFactoryBean |
An
AbstractFactoryBean for the StreamsBuilder instance
and lifecycle control for the internal KafkaStreams instance. |
| TopicBuilder |
Builder for a
NewTopic. |