インデックス

F

FACTORY_DOES_NOT_SUPPORT_METHOD - Static variable in interface org.springframework.kafka.core.ProducerFactory

サポートされていないファクトリメソッドのエラーメッセージ。

fail() - クラス org.springframework.kafka.streams のメソッド。AbstractRecoveringExceptionHandler

処理が失敗することを示すレスポンスを作成します。

fail() - クラス org.springframework.kafka.streams のメソッド。RecoveringDeserializationExceptionHandler

処理が失敗することを示すレスポンスを作成します。

fail() - クラス org.springframework.kafka.streams のメソッド。RecoveringProcessingExceptionHandler

処理が失敗することを示すレスポンスを作成します。

fail() - クラス org.springframework.kafka.streams のメソッド。RecoveringProductionExceptionHandler

処理が失敗することを示すレスポンスを作成します。

FAIL_ON_ERROR - Enum constant in enum class org.springframework.kafka.retrytopic.DltStrategy

DLT 処理がエラーをスローした場合は失敗します。

FailedBatchProcessor - org.springframework.kafka.listener のクラス

バッチを処理（および回復）できる FailedRecordProcessor のサブクラス。

FailedBatchProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler, CommonErrorHandler) - クラス org.springframework.kafka.listener. FailedBatchProcessor のコンストラクター

提供されたプロパティを使用してインスタンスを構築します。

FailedBatchProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, CommonErrorHandler) - クラス org.springframework.kafka.listener. FailedBatchProcessor のコンストラクター

提供されたプロパティを使用してインスタンスを構築します。

failedDelivery(ConsumerRecord<?, ?>, Exception, int) - クラス org.springframework.kafka.listener のメソッド。DeliveryAttemptAwareRetryListener

failedDelivery(ConsumerRecord<?, ?>, Exception, int) - インターフェース org.springframework.kafka.listener のメソッド。RetryListener

レコードの配信が失敗した後に呼び出されます。

failedDelivery(ConsumerRecords<?, ?>, Exception, int) - クラス org.springframework.kafka.listener のメソッド。DeliveryAttemptAwareRetryListener

バッチレコードの配信が失敗した後に呼び出します。

failedDelivery(ConsumerRecords<?, ?>, Exception, int) - インターフェース org.springframework.kafka.listener のメソッド。RetryListener

バッチレコードの配信が失敗した後に呼び出されます。

FailedDeserializationInfo - org.springframework.kafka.support.serializer のクラス

デシリアライズエラーに関するすべてのコンテキスト情報を含むクラス。

FailedDeserializationInfo(String, Headers, byte[], boolean, Exception) - クラス org.springframework.kafka.support.serializer. FailedDeserializationInfo のコンストラクター

コンテキスト情報を使用してインスタンスを構築します。

FailedRecordProcessor - org.springframework.kafka.listener のクラス

コンシューマーレコードの消費の失敗を処理するクラスの共通スーパークラス。

FailedRecordProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - クラス org.springframework.kafka.listener. FailedRecordProcessor のコンストラクター

FailedRecordProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler) - クラス org.springframework.kafka.listener. FailedRecordProcessor のコンストラクター

failure(Object, String) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

失敗を記録します。

failure(Object, String, Object) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

失敗を記録します。

failure(ConsumerRecord<K, V>, Exception, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeRecordInterceptor

failure(ConsumerRecord<K, V>, Exception, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。RecordInterceptor

リスナーが例外をスローした後に呼び出されます。

failure(ConsumerRecords<K, V>, Exception, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。BatchInterceptor

リスナーが例外をスローした後に呼び出されます。

failure(ConsumerRecords<K, V>, Exception, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeBatchInterceptor

FATAL - Enum constant in enum class org.springframework.kafka.KafkaException.Level

重大。

FATAL - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level

重大。

FENCED - Enum constant in enum class org.springframework.kafka.event.ConsumerStoppedEvent.Reason

トランザクションプロデューサーはフェンスで囲まれており、コンテナー stopContainerWhenFenced プロパティは true です。

filter() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

RecordFilterStrategy Bean 名を設定して、コンテナーファクトリで構成された戦略をオーバーライドします。

filter(ConsumerRecord<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractFilteringMessageListener

filter(ConsumerRecord<K, V>) - インターフェース org.springframework.kafka.listener.adapter のメソッド。RecordFilterStrategy

レコードを破棄する必要がある場合は true を返します。

filterBatch(List<ConsumerRecord<K, V>>) - インターフェース org.springframework.kafka.listener.adapter のメソッド。RecordFilterStrategy

レコードのバッチ全体をフィルタリングします。すべてのレコードをフィルタリングするには、null ではなく空のリストを返します。

FilteringBatchMessageListenerAdapter< K , V > - Class in org.springframework.kafka.listener.adapter

RecordFilterStrategy を介してフィルターロジックを実装する BatchMessageListener アダプター。

FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V>, RecordFilterStrategy<K, V>) - クラス org.springframework.kafka.listener.adapter. FilteringBatchMessageListenerAdapter のコンストラクター

提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。

FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - クラス org.springframework.kafka.listener.adapter. FilteringBatchMessageListenerAdapter のコンストラクター

提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。

FilteringMessageListenerAdapter< K , V > - Class in org.springframework.kafka.listener.adapter

RecordFilterStrategy を介してフィルターロジックを実装する MessageListener アダプター。

FilteringMessageListenerAdapter(MessageListener<K, V>, RecordFilterStrategy<K, V>) - クラス org.springframework.kafka.listener.adapter. FilteringMessageListenerAdapter のコンストラクター

提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。

FilteringMessageListenerAdapter(MessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - クラス org.springframework.kafka.listener.adapter. FilteringMessageListenerAdapter のコンストラクター

提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。

findDelegate(String) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

トピックのデリゲートを決定します。

findDelegate(T) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTypeSerializer

findDelegate(T, Map<Class<?>, Serializer<?>>) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTypeSerializer

データ型のシリアライザーを決定します。

findHandlerForPayload(Class<? extends Object>) - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler

findRetryConfigurationFor(String[], Method, Class<?>, Object) - クラス org.springframework.kafka.annotation のメソッド。RetryTopicConfigurationProvider

再試行トピック構成を見つけます。

findRetryConfigurationFor(String[], Method, Object) - クラス org.springframework.kafka.annotation のメソッド。RetryTopicConfigurationProvider

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

ListenerExecutionFailedException および TimestampedException を無視して、根本原因を見つけます。

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

FixedBackOff を構成します。

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

FixedBackOff を構成します。

flush() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer

flush() - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

プロデューサーをフラッシュします。

flush() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

プロデューサーをフラッシュします。

flush() - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate

forAllowList() - Static method in class org.springframework.kafka.support.ExceptionMatcher

例外型の構成可能なリストにある例外のみに一致するマッチャーのビルダーを作成します。

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

forDenyList() - Static method in class org.springframework.kafka.support.ExceptionMatcher

例外型の構成可能なリストに見つからない例外のみに一致するマッチャーのビルダーを作成します。

forInboundOnlyWithMatchers(ObjectMapper, String...) - Static method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper

使用すべきではありません。

パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。

forInboundOnlyWithMatchers(String...) - Static method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper

使用すべきではありません。

パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。

forInboundOnlyWithMatchers(String...) - Static method in class org.springframework.kafka.support.JsonKafkaHeaderMapper

パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。

forInboundOnlyWithMatchers(String...) - Static method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper

パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。

forInboundOnlyWithMatchers(JsonMapper, String...) - Static method in class org.springframework.kafka.support.JsonKafkaHeaderMapper

パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。

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

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

キーを逆直列化するためにこのデシリアライザーを指定します（デフォルトは値です）。デフォルトの型マッパーが使用されている場合にのみ適用されます。

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerde

キーを直列化 / 逆直列化するためにこの Serde を指定します（デフォルトは値です）。

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

キーを直列化するためにこのシリアライザーを指定します（デフォルトは値です）。デフォルトの型マッパーが使用されている場合にのみ適用されます。

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

使用すべきではありません。

キーを逆直列化するためにこのデシリアライザーを指定します（デフォルトは値です）。デフォルトの型マッパーが使用されている場合にのみ適用されます。

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

使用すべきではありません。

キーを直列化 / 逆直列化するためにこの Serde を指定します（デフォルトは値です）。

forKeys() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

使用すべきではありません。

キーを直列化するためにこのシリアライザーを指定します（デフォルトは値です）。デフォルトの型マッパーが使用されている場合にのみ適用されます。

format(ConsumerRecord<?, ?>) - Static method in class org.springframework.kafka.support.KafkaUtils

ロギング用に ConsumerRecord をフォーマットします。デフォルトの topic-partition@offset。

format(ProducerRecord<?, ?>) - Static method in class org.springframework.kafka.support.KafkaUtils

ロギング用に ProducerRecord をフォーマットします。デフォルトは ProducerRecordObject.toString() です。

fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress

fromClass(Class<?>, Headers) - インターフェース org.springframework.kafka.support.mapping のメソッド。ClassMapper

fromClass(Class<?>, Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

使用すべきではありません。

fromClass(Class<?>, Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

fromHeaders(MessageHeaders, Headers) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper

使用すべきではありません。

fromHeaders(MessageHeaders, Headers) - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper

fromHeaders(MessageHeaders, Headers) - インターフェース org.springframework.kafka.support のメソッド。KafkaHeaderMapper

指定された MessageHeaders から指定されたターゲットヘッダーにマップします。

fromHeaders(MessageHeaders, Headers) - クラス org.springframework.kafka.support のメソッド。SimpleKafkaHeaderMapper

fromJavaType(JavaType, Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

使用すべきではありません。

fromJavaType(JavaType, Headers) - インターフェース org.springframework.kafka.support.mapping のメソッド。Jackson2JavaTypeMapper

使用すべきではありません。

fromJavaType(JavaType, Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

fromJavaType(JavaType, Headers) - インターフェース org.springframework.kafka.support.mapping のメソッド。JacksonJavaTypeMapper

fromMessage(Message<?>, String) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

fromMessage(Message<?>, String) - インターフェース org.springframework.kafka.support.converter のメソッド。RecordMessageConverter

メッセージをプロデューサーレコードに変換します。

fromMessage(Message<?>, String) - インターフェース org.springframework.kafka.support.converter のメソッド。BatchMessageConverter

メッセージをプロデューサーレコードに変換します。

fromMessage(Message<?>, String) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

fromUserHeader(String, Header, Map<String, Object>) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

DefaultKafkaHeaderMapper 内の予約されていないヘッダーを処理します。