Uses of Class
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec in org.springframework.integration.kafka.dsl
Modifier and TypeMethodDescriptionKafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec.defaultReplyTimeout
(Duration replyTimeout) Default reply timeout.KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec.taskScheduler
(TaskScheduler scheduler) Modifier and TypeMethodDescriptionKafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec.configureKafkaTemplate
(Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) Configure a Kafka Template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.