パッケージ org.springframework.integration.kafka.dsl

クラス KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>

java.lang.ObjectSE
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>
型パラメーター:
K - 鍵の型。
V - 送信値型。
R - 応答値の型。
S - KafkaProducerMessageHandlerSpec 拡張型。
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<KafkaProducerMessageHandler<K,V>>、InitializingBean、Lifecycle、Phased、SmartLifecycle
既知の直属サブクラス
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec
public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> extends KafkaProducerMessageHandlerSpec<K,V,S>
ゲートウェイとしての KafkaProducerMessageHandler の MessageHandlerSpec 実装。
導入:
5.4
作成者:
Gary Russell

  • メソッドの詳細

    • replyMessageConverter

      public S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
      返信用のメッセージコンバーターを設定します（ゲートウェイの場合）。
      パラメーター:
      messageConverter - コンバーター。
      戻り値:
      スペック。

    • assigmentDuration

      public S assigmentDuration(DurationSE duration)
      デフォルトの返信先トピック / パーティションを決定するために、ゲートウェイとして使用される場合に、パーティションの割り当てを待機する時間を設定します。
      パラメーター:
      duration - デュレーション。
      戻り値:
      スペック。
      導入:
      6.0