Package org.springframework.integration.kafka.dsl

Provides Kafka Components support for Spring Integration Java DSL.

Class Summary

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.