パッケージ org.springframework.boot.autoconfigure.kafka

クラス ConcurrentKafkaListenerContainerFactoryConfigurer

java.lang.ObjectSE
org.springframework.boot.autoconfigure.kafka.ConcurrentKafkaListenerContainerFactoryConfigurer
public class ConcurrentKafkaListenerContainerFactoryConfigurer extends ObjectSE
ConcurrentKafkaListenerContainerFactory を適切なデフォルトで設定します。
導入:
1.5.0
作成者:
Gary Russell, Edd ú Mel é ndez, Thomas K å sene, Moritz Halbritter

  • コンストラクターの詳細

    • ConcurrentKafkaListenerContainerFactoryConfigurer

      public ConcurrentKafkaListenerContainerFactoryConfigurer()

  • メソッドの詳細

    • setCommonErrorHandler

      public void setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler)
      使用する CommonErrorHandler を設定します。
      パラメーター:
      commonErrorHandler - エラーハンドラー。
      導入:
      2.6.0

    • configure

      public void configure(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<ObjectSE,ObjectSE> listenerFactory, org.springframework.kafka.core.ConsumerFactory<ObjectSE,ObjectSE> consumerFactory)
      指定された Kafka リスナーコンテナーファクトリを構成します。ファクトリでさらに調整したり、デフォルト設定を上書きしたりできます。
      パラメーター:
      listenerFactory - 構成する ConcurrentKafkaListenerContainerFactory インスタンス
      consumerFactory - 使用する ConsumerFactory