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

    • recoveryCallback

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

    • getComponentsToRegister

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