| Interface | Description |
|---|---|
| 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. |
| 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. |
| 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. |