K
- the key type.V
- the outbound value type.R
- the reply value type.public static class KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> extends KafkaOutboundGatewaySpec<K,V,R,KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>> implements org.springframework.integration.dsl.ComponentsRegistration
KafkaTemplate
-based KafkaProducerMessageHandlerSpec
extension.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>, KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
Modifier and Type | Method and Description |
---|---|
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> |
configureKafkaTemplate(java.util.function.Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>> configurer)
Configure a Kafka Template by invoking the
Consumer callback, with a
KafkaTemplateSpec argument. |
java.util.Map<java.lang.Object,java.lang.String> |
getComponentsToRegister() |
replyMessageConverter
headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
public KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> configureKafkaTemplate(java.util.function.Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>> configurer)
Consumer
callback, with a
KafkaTemplateSpec
argument.configurer
- the configurer Java 8 Lambda.public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()
getComponentsToRegister
in interface org.springframework.integration.dsl.ComponentsRegistration