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() |
replyMessageConverterheaderMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpressionpublic 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