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>> AMessagingGatewaySpecimplementation for theKafkaInboundGateway.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> AConcurrentMessageListenerContainerconfigurationKafkaInboundGatewaySpecextension.KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> AMessageProducerSpecimplementation for theKafkaMessageDrivenChannelAdapter.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> AConcurrentMessageListenerContainerconfigurationKafkaMessageDrivenChannelAdapterSpecextension.KafkaMessageListenerContainerSpec<K,V> A helper class in the Builder pattern style to delegate options to theConcurrentMessageListenerContainer.KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> AMessageHandlerSpecimplementation for theKafkaProducerMessageHandleras a gateway.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> AKafkaTemplate-basedKafkaProducerMessageHandlerSpecextension.KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> AnIntegrationComponentSpecimplementation for theKafkaTemplate.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>> AMessageHandlerSpecimplementation for theKafkaProducerMessageHandler.KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> AKafkaTemplate-basedKafkaProducerMessageHandlerSpecextension.KafkaPublishSubscribeChannelSpec Spec for a publish/subscribe channel backed by a Kafka topic.KafkaSubscribableChannelSpec<C extends SubscribableKafkaChannel> Spec for a subscribable channel.KafkaTemplateSpec<K,V> AnIntegrationComponentSpecimplementation for theKafkaTemplate.