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
MessageListenerContainer s. |
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 . |
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 . |