Class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<S,KafkaProducerMessageHandler<K,V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec<K,V,S>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec<K,V,R,S>
- Type Parameters:
K
- the key type.V
- the outbound value type.R
- the reply value type.S
- theKafkaProducerMessageHandlerSpec
extension type.
- All Implemented Interfaces:
DisposableBean
,FactoryBean<KafkaProducerMessageHandler<K,
,V>> InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
- Direct Known Subclasses:
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec
public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>
extends KafkaProducerMessageHandlerSpec<K,V,S>
A
MessageHandlerSpec
implementation for the KafkaProducerMessageHandler
as a gateway.- Since:
- 5.4
- Author:
- Gary Russell
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
AKafkaTemplate
-basedKafkaProducerMessageHandlerSpec
extension.static class
AnIntegrationComponentSpec
implementation for theKafkaTemplate
.Nested classes/interfaces inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,
V> -
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
logger, PARSER, target
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Method Summary
Modifier and TypeMethodDescriptionassigmentDuration
(Duration duration) Set the time to wait for partition assignment, when used as a gateway, to determine the default reply-to topic/partition.replyMessageConverter
(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) Set a message converter for replies (when a gateway).Methods inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, producerRecordCreator, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression, useTemplateConverter
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.beans.factory.FactoryBean
isSingleton
-
Method Details
-
replyMessageConverter
public S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) Set a message converter for replies (when a gateway).- Parameters:
messageConverter
- the converter.- Returns:
- the spec.
-
assigmentDuration
Set the time to wait for partition assignment, when used as a gateway, to determine the default reply-to topic/partition.- Parameters:
duration
- the duration.- Returns:
- the spec.
- Since:
- 6.0
-