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