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.
|
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 . |
SimpleKafkaListenerContainerFactory<K,V> |
A
KafkaListenerContainerFactory implementation to build a regular
ConcurrentMessageListenerContainer . |
SimpleKafkaListenerEndpoint<K,V> |
A
KafkaListenerEndpoint simply providing the MessageListener to
invoke to process an incoming message for this endpoint. |