クラスの使用
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インスタンスを返します。DefaultDestinationTopicResolver.getDltFor(StringSE mainListenerId, StringSE topicName, ExceptionSE e) default DestinationTopic非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。default DestinationTopicDestinationTopicContainer.getDltFor(StringSE mainListenerId, StringSE topicName, ExceptionSE exc) スローされた例外を考慮して、指定されたトピックの DLT として登録されたDestinationTopicインスタンスを返します。見つからない場合は null を返します。protected DestinationTopicDefaultDestinationTopicResolver.DestinationTopicHolder.getNextDestination()DefaultDestinationTopicResolver.getNextDestinationTopicFor(StringSE mainListenerId, 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 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)
DestinationTopicContainer.getDltFor(String, String, Exception)に置き換えられました