クラス KafkaMessageDrivenChannelAdapterSpec<K, V, S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>>

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec <S、KafkaMessageDrivenChannelAdapter <K、V>>
org.springframework.integration.dsl.MessageProducerSpec <S、KafkaMessageDrivenChannelAdapter <K、V>>
org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec<K,V,S>
型パラメーター:
K - 鍵の型。
V - 値の型。
S - ターゲット KafkaMessageDrivenChannelAdapterSpec 実装型。
実装済みのインターフェース一覧:
DisposableBean, FactoryBean<KafkaMessageDrivenChannelAdapter<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
既知の直属サブクラス
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
public class KafkaMessageDrivenChannelAdapterSpec<K, V, S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> extends MessageProducerSpec<S, KafkaMessageDrivenChannelAdapter<K,V>> implements ComponentsRegistration
KafkaMessageDrivenChannelAdapter の MessageProducerSpec 実装。
導入:
5.4
作成者:
Artem Bilan, Gary Russell, Cameron Mayfield

  • 方法の詳細

    • messageConverter

      public S messageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter)
      メッセージコンバーターを設定します。モードに応じて、RecordMessageConverter または BatchMessageConverter でなければなりません。
      パラメーター:
      messageConverter - コンバーター。
      戻り値:
      スペック

    • recordMessageConverter

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

    • batchMessageConverter

      public S batchMessageConverter(org.springframework.kafka.support.converter.BatchMessageConverter messageConverter)
      メッセージコンバーターを設定して、バッチベースのコンシューマーで使用します。
      パラメーター:
      messageConverter - コンバーター。
      戻り値:
      スペック

    • recordFilterStrategy

      public S recordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)
      KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener を FilteringMessageListenerAdapter にラップする RecordFilterStrategy を指定します。
      パラメーター:
      recordFilterStrategy - 使用する RecordFilterStrategy。
      戻り値:
      スペック

    • ackDiscarded

      public S ackDiscarded(boolean ackDiscarded)
      FilteringMessageListenerAdapter が破棄されたレコードを確認する必要があるかどうかを示す boolean フラグ。recordFilterStrategy(RecordFilterStrategy) が指定されていない場合は意味がありません。
      パラメーター:
      ackDiscarded - 破棄されたメッセージに確認応答（コミットオフセット）する場合は true。
      戻り値:
      スペック

    • retryTemplate

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

    • recoveryCallback

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

    • payloadType

      public S payloadType(ClassSE<?> payloadType)
      型認識メッセージコンバーター ( StringJsonMessageConverter など) を使用する場合、コンバーターが作成するペイロード型を設定します。デフォルトは ObjectSE です。
      パラメーター:
      payloadType - 型。
      戻り値:
      スペック

    • filterInRetry

      public S filterInRetry(boolean filterInRetry)
      boolean フラグは、フィルター処理と再試行処理の実行順序を指定します。RetryTemplate または RecordFilterStrategy のいずれか一方のみ、またはどちらも指定されていない場合は、このフラグは意味を持ちません。true の場合、フィルターは再試行ごとに呼び出されます。false の場合、フィルターはコンテナーからの配信ごとに 1 回だけ呼び出されます。
      パラメーター:
      filterInRetry - 再試行ごとにフィルター処理する場合は true。デフォルトは false です。
      戻り値:
      スペック

    • 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