Uses of Class
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaOutboundGatewaySpec in org.springframework.integration.kafka.dsl
Modifier and TypeClassDescriptionclass
KafkaOutboundGatewaySpec<K,
V, R, S extends KafkaOutboundGatewaySpec<K, V, R, S>> AMessageHandlerSpec
implementation for theKafkaProducerMessageHandler
as a gateway.Modifier and TypeClassDescriptionstatic class
AKafkaTemplate
-basedKafkaProducerMessageHandlerSpec
extension.Modifier and TypeMethodDescriptionstatic <K,
V, R> KafkaOutboundGatewaySpec<K, V, R, ?> Kafka.outboundGateway
(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K, V, R> kafkaTemplate) Create an initialKafkaProducerMessageHandlerSpec
.