Uses of Class
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec in org.springframework.integration.kafka.dsl
Modifier and TypeMethodDescriptionKafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec.configureKafkaTemplate
(Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) Configure a Kafka Template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.static <K,
V, R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K, V, R> Kafka.outboundGateway
(org.springframework.kafka.core.ProducerFactory<K, V> producerFactory, org.springframework.kafka.listener.GenericMessageListenerContainer<K, R> replyContainer) Create an initialKafkaProducerMessageHandlerSpec
with ProducerFactory.