K
- the key type.V
- the outbound value type.R
- the reply value type.S
- the KafkaProducerMessageHandlerSpec
extension type.public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> extends KafkaProducerMessageHandlerSpec<K,V,S>
MessageHandlerSpec
implementation for the KafkaProducerMessageHandler
as a gateway.Modifier and Type | Class and Description |
---|---|
static class |
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
A
KafkaTemplate -based KafkaProducerMessageHandlerSpec extension. |
static class |
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>
An
IntegrationComponentSpec implementation for the KafkaTemplate . |
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
Modifier and Type | Method and Description |
---|---|
S |
replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
Set a message converter for replies (when a gateway).
|
headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression
public S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
messageConverter
- the converter.