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

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec <S、KafkaInboundGateway <K、V、R>>
org.springframework.integration.dsl.MessagingGatewaySpec <S、KafkaInboundGateway <K、V、R>>
org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec<K,V,R,S>
型パラメーター:
K - 鍵の型。
V - リクエスト値型。
R - 応答値の型。
S - ターゲット KafkaInboundGatewaySpec 実装型。
実装されているすべてのインターフェース:
DisposableBean、FactoryBean<KafkaInboundGateway<K,V,R>>、InitializingBean、Lifecycle、Phased、SmartLifecycle、ComponentsRegistration
既知の直属サブクラス
KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec
public class KafkaInboundGatewaySpec<K, V, R, S extends KafkaInboundGatewaySpec<K,V,R,S>> extends MessagingGatewaySpec<S, KafkaInboundGateway<K,V,R>> implements ComponentsRegistration
KafkaInboundGateway の MessagingGatewaySpec 実装。
導入:
5.4
作成者:
Gary Russell, Artem Bilan

  • メソッドの詳細

    • messageConverter

      public S messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
      レコードコンバーターを使用するようにメッセージコンバーターを設定します。
      パラメーター:
      messageConverter - コンバーター。
      戻り値:
      スペック

    • retryTemplate

      public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
      配信の再試行に使用する RetryTemplate インスタンスを指定します。
      パラメーター:
      retryTemplate - 使用する RetryTemplate。
      戻り値:
      スペック

    • recoveryCallback

      public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
      再試行操作用の RecoveryCallback インスタンス。null の場合、再試行が終了した後に例外がコンテナーにスローされます。retryTemplate(RetryTemplate) が指定されていない場合は意味がありません。
      パラメーター:
      recoveryCallback - リカバリコールバック。
      戻り値:
      スペック

    • onPartitionsAssignedSeekCallback

      public S onPartitionsAssignedSeekCallback(BiConsumerSE<MapSE<org.apache.kafka.common.TopicPartition, LongSE>, org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback> onPartitionsAssignedCallback)
      シーク管理のための BiConsumerSE を指定します
      無効な参照 
      ConsumerSeekAware.ConsumerSeekCallback#onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback)
       KafkaMessageListenerContainer からの呼び出し。
      パラメーター:
      onPartitionsAssignedCallback - 使用する BiConsumerSE
      戻り値:
      スペック

    • getComponentsToRegister

      public MapSE<ObjectSE,StringSE> getComponentsToRegister()
      次で指定:
      インターフェース ComponentsRegistration の getComponentsToRegister