Class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>

Type Parameters:
K - the key type.
V - the outbound value type.
R - the reply value type.
S - the KafkaProducerMessageHandlerSpec extension type.
All Implemented Interfaces:
Aware, BeanClassLoaderAware, BeanFactoryAware, 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
  • 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

      public S assigmentDuration(Duration duration)
      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