Uses of Class
org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaMessageDrivenChannelAdapterSpec in org.springframework.integration.kafka.dsl
Modifier and TypeClassDescriptionclass
KafkaMessageDrivenChannelAdapterSpec<K,
V, S extends KafkaMessageDrivenChannelAdapterSpec<K, V, S>> AMessageProducerSpec
implementation for theKafkaMessageDrivenChannelAdapter
.Modifier and TypeClassDescriptionstatic class
AConcurrentMessageListenerContainer
configurationKafkaMessageDrivenChannelAdapterSpec
extension.Modifier and TypeMethodDescriptionstatic <K,
V> KafkaMessageDrivenChannelAdapterSpec<K, V, ?> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.listener.AbstractMessageListenerContainer<K, V> listenerContainer) Create an initialKafkaMessageDrivenChannelAdapterSpec
.static <K,
V> KafkaMessageDrivenChannelAdapterSpec<K, V, ?> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.listener.AbstractMessageListenerContainer<K, V> listenerContainer, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode) Create an initialKafkaMessageDrivenChannelAdapterSpec
.