クラスの使用
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
RetryTopicConfigurationBuilder を使用するパッケージ
org.springframework.kafka.retrytopic 内の RetryTopicConfigurationBuilder 使用
修飾子と型メソッド説明RetryTopicConfigurationBuilder.autoCreateTopics(@Nullable BooleanSE shouldCreate, @Nullable IntegerSE numPartitions, @Nullable ShortSE replicationFactor) オプションで、提供されたプロパティを使用してトピックを作成するようにトピック作成動作を構成します。RetryTopicConfigurationBuilder.autoCreateTopicsWith(@Nullable IntegerSE numPartitions, @Nullable ShortSE replicationFactor) 指定されたプロパティを使用してトピックを自動作成するようにトピック作成動作を構成します。RetryTopicConfigurationBuilder.autoStartDltHandler(@Nullable BooleanSE autoStart) DLT ハンドラー (構成済みまたはデフォルト) を開始しない場合は false に設定し、コンテナーファクトリの autoStartup プロパティをオーバーライドします。RetryTopicConfigurationBuilder.concurrency(IntegerSE concurrency) 再試行コンテナーと DLT コンテナーの同時実行を構成します。RetryTopicConfigurationBuilder.customBackoff(BackOff backOff) カスタムBackOffを構成します。RetryTopicConfigurationBuilder.dltHandlerMethod(StringSE beanName, StringSE methodName) DLT ハンドラーメソッドを設定します。RetryTopicConfigurationBuilder.dltHandlerMethod(EndpointHandlerMethod endpointHandlerMethod) DLT ハンドラーメソッドを設定します。RetryTopicConfigurationBuilder.dltProcessingFailureStrategy(DltStrategy dltStrategy) DltStrategyを構成します。RetryTopicConfigurationBuilder.dltRoutingRules(MapSE<StringSE, SetSE<ClassSE<? extends ThrowableSE>>> dltRoutingRules) メッセージ処理中に構成された例外がスローされた場合に、メッセージがカスタム DLT にリダイレクトされるように DLT ルーティングルールを設定するように構成します。DLT トピックに追加するサフィックスを構成します。RetryTopicConfigurationBuilder.doNotAutoCreateRetryTopics()トピックを自動作成しないようにトピック作成動作を構成します。RetryTopicConfigurationBuilder.doNotConfigureDlt()DltStrategyをDltStrategy.NO_DLTに構成します。RetryTopicConfigurationBuilder.doNotRetryOnDltFailure()DltStrategyをDltStrategy.FAIL_ON_ERRORに構成します。RetryTopicConfigurationBuilder.excludeTopic(StringSE topicName) ターゲット構成が使用されないトピック名を構成します。RetryTopicConfigurationBuilder.excludeTopics(ListSE<StringSE> topicNames) ターゲット構成が使用されないトピック名を構成します。RetryTopicConfigurationBuilder.exponentialBackoff(long initialInterval, double multiplier, long maxInterval) ExponentialBackOffを構成します。RetryTopicConfigurationBuilder.exponentialBackoff(long initialInterval, double multiplier, long maxInterval, long jitter) ジッター値を使用してExponentialBackOffを設定します。RetryTopicConfigurationBuilder.fixedBackOff(int interval) FixedBackOffを構成します。RetryTopicConfigurationBuilder.fixedBackOff(long interval) FixedBackOffを構成します。RetryTopicConfigurationBuilder.includeTopic(StringSE topicName) ターゲット構成を使用するトピック名を構成します。RetryTopicConfigurationBuilder.includeTopics(ListSE<StringSE> topicNames) ターゲット構成を使用するトピック名を構成します。RetryTopicConfigurationBuilder.listenerFactory(@Nullable StringSE factoryBeanName) Bean 名を介して使用するコンテナーファクトリを構成します。RetryTopicConfigurationBuilder.listenerFactory(ConcurrentKafkaListenerContainerFactory<?, ?> factory) 使用するコンテナーファクトリを構成します。RetryTopicConfigurationBuilder.maxAttempts(int maxAttempts) 配信の最大試行回数 (初回を含む) を構成します。RetryTopicConfigurationBuilder.newInstance()ビルダーの新しいインスタンスを作成します。RetryTopicConfigurationBuilder.noBackoff()遅延を適用しないBackOffを構成します。RetryTopicConfigurationBuilder.notRetryOn(ClassSE<? extends ThrowableSE> throwable) 提供されたThrowableSE で再試行しないように動作を構成します。RetryTopicConfigurationBuilder.notRetryOn(ListSE<ClassSE<? extends ThrowableSE>> throwables) 提供されたThrowableSE で再試行しないように動作を構成します。RetryTopicConfigurationBuilder.retryOn(ClassSE<? extends ThrowableSE> throwable) 提供されたThrowableSE で再試行するように動作を構成します。RetryTopicConfigurationBuilder.retryOn(ListSE<ClassSE<? extends ThrowableSE>> throwables) 提供されたThrowableSE で再試行するように動作を構成します。RetryTopicConfigurationBuilder.retryTopicSuffix(@Nullable StringSE suffix) 再試行トピックに追加するサフィックスを構成します。RetryTopicConfigurationBuilder.sameIntervalTopicReuseStrategy(SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy) SameIntervalTopicReuseStrategyを構成します。RetryTopicConfigurationBuilder.setTopicSuffixingStrategy(TopicSuffixingStrategy topicSuffixingStrategy) 再試行トピック名TopicSuffixingStrategyを構成します。RetryTopicConfigurationBuilder.suffixTopicsWithIndexValues()再試行トピック名の末尾に序数のインデックス値を付けるように構成します。RetryTopicConfigurationBuilder.timeoutAfter(long timeout) ミリ秒単位でグローバルタイムアウトを構成します。その後、リスナーが次に例外をスローしたときにレコードが DLT に直接送信されます。RetryTopicConfigurationBuilder.traversingCauses()原因 チェーンをトラバースするように分類子を構成します。RetryTopicConfigurationBuilder.traversingCauses(boolean traversing) 原因 チェーンをトラバースするか、トラバースしないように分類子を構成します。RetryTopicConfigurationBuilder.uniformRandomBackoff(long minInterval, long maxInterval) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。RetryTopicConfigurationBuilder.useSingleTopicForSameIntervals()同じバックオフ間隔を持つ試行に対して、単一の再試行トピックの使用を構成します (これらの試行が チェーンの終わりにある場合)。
exponentialBackoff(long, double, long)を推奨