Uses of Class
org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec in org.springframework.integration.kafka.dsl
Modifier and TypeMethodDescriptionKafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureListenerContainer
(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumer
callback, with aKafkaMessageListenerContainerSpec
argument.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureTemplate
(Consumer<KafkaTemplateSpec<K, R>> configurer) Configure a template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.static <K,
V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway
(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpec
with the provided container and template specs.static <K,
V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway
(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, org.springframework.kafka.core.ProducerFactory<K, R> producerFactory) Create an initialKafkaInboundGatewaySpec
with the provided consumer factory, container properties and producer factory.