See: Description
| Class | Description |
|---|---|
| AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>,C extends AbstractKafkaChannel> |
Spec for a message channel backed by a Kafka topic.
|
| 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. |
| KafkaPointToPointChannelSpec |
Spec for a point to point channel backed by a Kafka topic.
|
| KafkaPollableChannelSpec |
Spec for a pollable channel.
|
| KafkaProducerMessageHandlerSpec<K,V,S extends KafkaProducerMessageHandlerSpec<K,V,S>> |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler. |
| KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
A
KafkaTemplate-based KafkaProducerMessageHandlerSpec extension. |
| KafkaPublishSubscribeChannelSpec |
Spec for a publish/subscribe channel backed by a Kafka topic.
|
| KafkaSubscribableChannelSpec<C extends SubscribableKafkaChannel> |
Spec for a subscribable channel.
|
| KafkaTemplateSpec<K,V> |
An
IntegrationComponentSpec implementation for the KafkaTemplate. |