Uses of Class
org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec
Packages that use KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec in org.springframework.integration.kafka.dsl
Methods in org.springframework.integration.kafka.dsl that return KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpecModifier and TypeMethodDescriptionKafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumercallback, with aKafkaMessageListenerContainerSpecargument.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureTemplate(Consumer<KafkaTemplateSpec<K, R>> configurer) Configure a template by invoking theConsumercallback, with aKafkaTemplateSpecargument.static <K,V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpecwith 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 initialKafkaInboundGatewaySpecwith the provided consumer factory, container properties and producer factory.