Enum クラスの使用箇所
org.springframework.kafka.KafkaException.Level
KafkaException.Level を使用するパッケージ
パッケージ
説明
kafka の基本パッケージ
kafka リスナーのためのパッケージ
org.springframework.kafka 内の KafkaException.Level 使用
org.springframework.kafka 内の KafkaException.Level 型の型引数を持つサブクラス修飾子と型メソッド説明static KafkaException.Level指定された名前でこのクラスの列挙型定数を返します。static KafkaException.Level[]KafkaException.Level.values()この列挙型クラスの定数を含む配列を、宣言されている順序で返します。型 KafkaException.Level のパラメーターを持つ org.springframework.kafka のコンストラクター修飾子コンストラクター説明KafkaException(StringSE message, KafkaException.Level level, @Nullable ThrowableSE cause) 提供されたプロパティを使用してインスタンスを構築します。org.springframework.kafka.listener 内の KafkaException.Level 使用
修飾子と型メソッド説明protected KafkaException.LevelKafkaExceptionLogLevelAware.getLogLevel()このハンドラーによってスローされた例外がログに記録されるレベルを設定します。型 KafkaException.Level のパラメーターを持つ org.springframework.kafka.listener のメソッド修飾子と型メソッド説明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) コンシューマーを一時停止して完全なバッチを再試行し、ループでコンシューマーをポーリングし、次のバックオフを待ってから、リスナーを呼び出します。static voidSeekUtils.seekOrRecover(ExceptionSE thrownException, @Nullable ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean commitRecovered, RecoveryStrategy recovery, LogAccessor logger, KafkaException.Level level) 残りのレコードを探し、オプションで最初のレコードを回復します。static voidSeekUtils.seekOrRecover(ExceptionSE thrownException, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean commitRecovered, BiPredicateSE<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, ExceptionSE> skipPredicate, LogAccessor logger, KafkaException.Level level) 残りのレコードを探し、オプションで最初のレコードを回復します。voidFailedBatchProcessor.setLogLevel(KafkaException.Level logLevel) voidKafkaExceptionLogLevelAware.setLogLevel(KafkaException.Level logLevel) このハンドラーによってスローされた例外がログに記録されるレベルを設定します。