クラスの使用
org.springframework.kafka.retrytopic.DestinationTopic
DestinationTopic を使用するパッケージ
org.springframework.kafka.retrytopic 内の DestinationTopic 使用
DestinationTopic 型の型パラメーターを持つ org.springframework.kafka.retrytopic のフィールド修飾子と型フィールド説明protected final MapSE<StringSE, ListSE<DestinationTopic>> DestinationTopicProcessor.Context.destinationsByTopicMap修飾子と型メソッド説明DefaultDestinationTopicResolver.getDestinationTopicByName(StringSE mainListenerId, StringSE topic) DestinationTopicContainer.getDestinationTopicByName(StringSE mainListenerId, StringSE topicName) そのトピックに登録されているDestinationTopicインスタンスを返します。@Nullable DestinationTopicDefaultDestinationTopicResolver.getDltFor(StringSE mainListenerId, StringSE topicName, @Nullable ExceptionSE e) default @Nullable DestinationTopicDestinationTopicContainer.getDltFor(StringSE mainListenerId, StringSE topicName, @Nullable ExceptionSE exc) スローされた例外を考慮して、指定されたトピックの DLT として登録されたDestinationTopicインスタンスを返します。見つからない場合は null を返します。protected DestinationTopicDefaultDestinationTopicResolver.DestinationTopicHolder.getNextDestination()DefaultDestinationTopicResolver.getNextDestinationTopicFor(StringSE mainListenerId, @Nullable StringSE topic) DestinationTopicContainer.getNextDestinationTopicFor(StringSE mainListenerId, StringSE topicName) 指定されたトピックの チェーンに次の宛先トピックとして登録されているDestinationTopicインスタンスを返します。protected DestinationTopicDefaultDestinationTopicResolver.DestinationTopicHolder.getSourceDestination()DefaultDestinationTopicResolver.resolveDestinationTopic(StringSE mainListenerId, StringSE topic, IntegerSE attempt, ExceptionSE e, long originalTimestamp) DestinationTopicResolver.resolveDestinationTopic(StringSE mainListenerId, StringSE topic, IntegerSE attempt, ExceptionSE e, long originalTimestamp) 失敗したメッセージの宛先トピックを解決します。型 DestinationTopic のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected voidDeadLetterPublishingRecovererFactory.maybeLogListenerException(ExceptionSE exception, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> consumerRecord, DestinationTopic nextDestination) エラーのあるレコードを再試行トピックに送信する前に、例外をログに記録します。protected org.apache.kafka.common.TopicPartitionDeadLetterPublishingRecovererFactory.resolveTopicPartition(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> cr, DestinationTopic nextDestination) 元のレコードを転送する必要があるTopicPartitionを作成して返します。型 DestinationTopic の型引数を持つ org.springframework.kafka.retrytopic のメソッドパラメーター修飾子と型メソッド説明voidDefaultDestinationTopicResolver.addDestinationTopics(StringSE mainListenerId, ListSE<DestinationTopic> destinationsToAdd) voidDestinationTopicContainer.addDestinationTopics(StringSE mainListenerId, ListSE<DestinationTopic> destinationTopics) 提供された宛先トピックをコンテナーに追加します。型 DestinationTopic のパラメーターを持つ org.springframework.kafka.retrytopic のコンストラクター修飾子コンストラクター説明DestinationTopic(StringSE destinationName, DestinationTopic sourceDestinationtopic, StringSE suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)