クラス DestinationTopicPropertiesFactory
java.lang.ObjectSE
org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory
提供された構成に基づいて
DestinationTopic.Properties
のリストを作成します。- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes, Gary Russell, Jo ã o Lima, Wang Zhiyang, Adrian Chlebosz
ネストされたクラスのサマリー
ネストされたクラスコンストラクターの概要
コンストラクターコンストラクター説明DestinationTopicPropertiesFactory
(StringSE retryTopicSuffix, StringSE dltSuffix, ListSE<LongSE> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout) 提供されたプロパティを使用してインスタンスを構築します。DestinationTopicPropertiesFactory
(StringSE retryTopicSuffix, StringSE dltSuffix, ListSE<LongSE> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, MapSE<StringSE, SetSE<ClassSE<? extends ThrowableSE>>> dltRoutingRules) 提供されたプロパティを使用してインスタンスを構築します。メソッドのサマリー
コンストラクターの詳細
DestinationTopicPropertiesFactory
public DestinationTopicPropertiesFactory(StringSE retryTopicSuffix, StringSE dltSuffix, ListSE<LongSE> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout) 提供されたプロパティを使用してインスタンスを構築します。- パラメーター:
retryTopicSuffix
- 接尾辞。dltSuffix
- dlt サフィックス。backOffValues
- バックオフ値。exceptionClassifier
- 例外分類子。numPartitions
- パーティションの数。kafkaOperations
- 操作。dltStrategy
- dlt 戦略。topicSuffixingStrategy
- トピック接尾辞戦略。sameIntervalTopicReuseStrategy
- 同じ間隔の再利用戦略。timeout
- タイムアウト。- 導入:
- 3.0.12
DestinationTopicPropertiesFactory
public DestinationTopicPropertiesFactory(StringSE retryTopicSuffix, StringSE dltSuffix, ListSE<LongSE> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, MapSE<StringSE, SetSE<ClassSE<? extends ThrowableSE>>> dltRoutingRules) 提供されたプロパティを使用してインスタンスを構築します。- パラメーター:
retryTopicSuffix
- 接尾辞。dltSuffix
- dlt サフィックス。backOffValues
- バックオフ値。exceptionClassifier
- 例外分類子。numPartitions
- パーティションの数。kafkaOperations
- 操作。dltStrategy
- dlt 戦略。topicSuffixingStrategy
- トピック接尾辞戦略。sameIntervalTopicReuseStrategy
- 同じ間隔の再利用戦略。timeout
- タイムアウト。dltRoutingRules
- 特定の例外型にどの DLT を使用するかの指定- 導入:
- 3.2.0
メソッドの詳細
autoStartDltHandler
DLT ハンドラーを開始しない場合は、false に設定します。- パラメーター:
autoStart
- 開始しない場合は false。- 戻り値:
- このファクトリ。
- 導入:
- 2.8
createProperties