インデックス

U

uniformRandomBackoff(long, long) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

UniformRandomBackOffPolicy を構成します。

unrecoverableBackOff(BackOff, ThreadLocal<BackOffExecution>, ThreadLocal<Long>, MessageListenerContainer) - Static method in class org.springframework.kafka.listener.ListenerUtils

非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

ListenerUtils.unrecoverableBackOff(BackOff, Map, Map, MessageListenerContainer) を推奨。

unrecoverableBackOff(BackOff, Map<Thread, BackOffExecution>, Map<Thread, Long>, MessageListenerContainer) - Static method in class org.springframework.kafka.listener.ListenerUtils

BackOff に従ってスリープします。BackOffExecution が前の backOff の BackOffExecution.STOP スリープを返したとき。

unregisterListenerContainer(String) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

指定された ID でリスナーコンテナーを登録解除します。

unregisterSeekCallback() - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware

unregisterSeekCallback() - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware

リスナーコンシューマーが終了したときに呼び出され、実装がスレッドローカルなどの状態をクリーンアップできるようにします。

unwrapIfNeeded(Exception) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

存在する場合は、TimestampedException を削除します。

updateConfigs(Map<String, Object>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

コンシューマー構成マップを更新します。資格情報のローテーションなどの状況で役立ちます。

updateConfigs(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

updateConfigs(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

updateConfigs(Map<String, Object>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

プロデューサー構成マップを更新します。クレデンシャルローテーションなどの状況で役立ちます。

USE_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

型ヘッダーを使用するための Kafka 構成プロパティ（デフォルトは true）。

usedForExceptions() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic.Properties

usedForExceptions() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic

useSingleTopicForSameIntervals() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

同じバックオフ間隔の試行に対して単一の再試行トピックの使用を構成します (これらの試行が チェーン の最後にある限り)。