See: Description
| Class | Description |
|---|---|
| Kafka |
Factory class for Apache Kafka components.
|
| KafkaInboundChannelAdapterSpec<K,V> |
Spec for a polled Kafka inbound channel adapter.
|
| KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>> |
A
MessagingGatewaySpec implementation for the KafkaInboundGateway. |
| KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> |
A
ConcurrentMessageListenerContainer configuration KafkaInboundGatewaySpec
extension. |
| KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> |
A
MessageProducerSpec implementation for the KafkaMessageDrivenChannelAdapter. |
| KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
A
ConcurrentMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec
extension. |
| KafkaMessageListenerContainerSpec<K,V> |
A helper class in the Builder pattern style to delegate options to the
ConcurrentMessageListenerContainer. |
| KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler
as a gateway. |
| KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> |
A
KafkaTemplate-based KafkaProducerMessageHandlerSpec extension. |
| KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> |
An
IntegrationComponentSpec implementation for the KafkaTemplate. |
| KafkaProducerMessageHandlerSpec<K,V,S extends KafkaProducerMessageHandlerSpec<K,V,S>> |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler. |
| KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
A
KafkaTemplate-based KafkaProducerMessageHandlerSpec extension. |
| KafkaTemplateSpec<K,V> |
An
IntegrationComponentSpec implementation for the KafkaTemplate. |