Uses of Package
org.springframework.integration.kafka.dsl
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
ClassDescriptionSpec for a message channel backed by an Apache Kafka topic.Spec for a polled Apache Kafka inbound channel adapter.A
MessagingGatewaySpec
implementation for theKafkaInboundGateway
.AConcurrentMessageListenerContainer
configurationKafkaInboundGatewaySpec
extension.AMessageProducerSpec
implementation for theKafkaMessageDrivenChannelAdapter
.AConcurrentMessageListenerContainer
configurationKafkaMessageDrivenChannelAdapterSpec
extension.A helper class in the Builder pattern style to delegate options to theConcurrentMessageListenerContainer
.AMessageHandlerSpec
implementation for theKafkaProducerMessageHandler
as a gateway.AKafkaTemplate
-basedKafkaProducerMessageHandlerSpec
extension.AnIntegrationComponentSpec
implementation for theKafkaTemplate
.Spec for a point to point channel backed by an Apache Kafka topic.Spec for a pollable channel.AMessageHandlerSpec
implementation for theKafkaProducerMessageHandler
.AKafkaTemplate
-basedKafkaProducerMessageHandlerSpec
extension.Spec for a publish/subscribe channel backed by an Apache Kafka topic.Spec for a subscribable channel.AnIntegrationComponentSpec
implementation for theKafkaTemplate
.