クラス 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(RetryTemplate retryTemplate)
      Specify a RetryTemplate instance to use for retrying deliveries.
      パラメーター:
      retryTemplate - 使用する RetryTemplate。
      戻り値:
      スペック

    • recoveryCallback

      public S recoveryCallback(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)
      KafkaMessageListenerContainer からの ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback) 呼び出し中にシーク管理用の BiConsumerSE を指定します。
      パラメーター:
      onPartitionsAssignedCallback - 使用する BiConsumerSE
      戻り値:
      スペック

    • getComponentsToRegister

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