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

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

java.lang.ObjectSE
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,​G>
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 実装型。
実装されているすべてのインターフェース:
Aware、BeanClassLoaderAware、BeanFactoryAware、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)
      KafkaInboundGateway.IntegrationRecordMessageListener を RetryingMessageListenerAdapter にラップする 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)
      KafkaMessageListenerContainer からの ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback) 呼び出し中にシーク管理用の BiConsumerSE を指定します。
      パラメーター:
      onPartitionsAssignedCallback - 使用する BiConsumerSE
      戻り値:
      スペック

    • getComponentsToRegister

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