クラスの使用
org.springframework.kafka.support.ExceptionMatcher
ExceptionMatcher を使用するパッケージ
パッケージ
説明
kafka リスナーのためのパッケージ
再試行可能なトピック処理用のパッケージ。
kafka サポート用パッケージ
org.springframework.kafka.listener 内の ExceptionMatcher 使用
修飾子と型メソッド説明protected ExceptionMatcherExceptionClassifier.getExceptionMatcher()ExceptionMatcherを返します。型 ExceptionMatcher のパラメーターを持つ org.springframework.kafka.listener のメソッド修飾子と型メソッド説明static @Nullable ExceptionSEErrorHandlingUtils.retryBatch(ExceptionSE thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, RunnableSE invokeListener, BackOffExecution execution, CommonErrorHandler seeker, BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecords<?, ?>, ExceptionSE> recoverer, LogAccessor logger, KafkaException.Level logLevel, ListSE<RetryListener> retryListeners, ExceptionMatcher exceptionMatcher, boolean reClassifyOnExceptionChange, boolean resetStateOnExceptionChange) コンシューマーを一時停止して完全なバッチを再試行し、ループでコンシューマーをポーリングし、次のバックオフを待ってから、リスナーを呼び出します。static voidErrorHandlingUtils.retryBatch(ExceptionSE thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, RunnableSE invokeListener, BackOff backOff, CommonErrorHandler seeker, BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecords<?, ?>, ExceptionSE> recoverer, LogAccessor logger, KafkaException.Level logLevel, ListSE<RetryListener> retryListeners, ExceptionMatcher exceptionMatcher, boolean reClassifyOnExceptionChange) 使用すべきではありません。org.springframework.kafka.retrytopic 内の ExceptionMatcher 使用
型 ExceptionMatcher のパラメーターを持つ org.springframework.kafka.retrytopic のコンストラクター修飾子コンストラクター説明DestinationTopicPropertiesFactory(@Nullable StringSE retryTopicSuffix, @Nullable StringSE dltSuffix, ListSE<LongSE> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, MapSE<StringSE, SetSE<ClassSE<? extends ThrowableSE>>> dltRoutingRules) 提供されたプロパティを使用してインスタンスを構築します。DestinationTopicPropertiesFactory(StringSE retryTopicSuffix, StringSE dltSuffix, ListSE<LongSE> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout) 提供されたプロパティを使用してインスタンスを構築します。org.springframework.kafka.support 内の ExceptionMatcher 使用
修飾子と型メソッド説明ExceptionMatcher.Builder.build()ExceptionMatcherを構築します。static ExceptionMatcherExceptionMatcher.defaultMatcher()任意のExceptionSE に一致するがエラーには一致しないマッチャーを作成します。
ErrorHandlingUtils.retryBatch(Exception, ConsumerRecords, Consumer, MessageListenerContainer, Runnable, BackOffExecution, CommonErrorHandler, BiConsumer, LogAccessor, KafkaException.Level, List, ExceptionMatcher, boolean, boolean)を推奨。