Uses of Class
org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec in org.springframework.integration.kafka.dsl
Modifier and TypeMethodDescriptionKafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec.configureListenerContainer
(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumer
callback, with aKafkaMessageListenerContainerSpec
argument.static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, String... topics) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, Pattern topicPattern) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, String... topics) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, Pattern topicPattern) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode) static <K,
V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K, V> Kafka.messageDrivenChannelAdapter
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions)