| Interface | Description |
|---|---|
| KafkaListenerContainerFactory<C extends MessageListenerContainer> |
Factory of
MessageListenerContainer based on a
KafkaListenerEndpoint definition. |
| KafkaListenerEndpoint |
Model for a Kafka listener endpoint.
|
| 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.
|
| 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. |
| 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. |
| SimpleKafkaListenerEndpoint<K,V> |
A
KafkaListenerEndpoint simply providing the MessageListener to
invoke to process an incoming message for this endpoint. |