インデックス

R

RAW_DATA - Static variable in class org.springframework.kafka.support.KafkaHeaders

Kafka（ConsumerRecord または ConsumerRecords）から受信した生データを含むヘッダー。

ReactiveKafkaConsumerTemplate< K , V > - Class in org.springframework.kafka.core.reactive

リアクティブ kafka コンシューマー操作の実装。

ReactiveKafkaConsumerTemplate(KafkaReceiver<K, V>) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaConsumerTemplate のコンストラクター

ReactiveKafkaConsumerTemplate(ReceiverOptions<K, V>) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaConsumerTemplate のコンストラクター

ReactiveKafkaProducerTemplate< K , V > - Class in org.springframework.kafka.core.reactive

リアクティブ kafka プロデューサー操作の実装。

ReactiveKafkaProducerTemplate(KafkaSender<K, V>) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaProducerTemplate のコンストラクター

ReactiveKafkaProducerTemplate(KafkaSender<K, V>, RecordMessageConverter) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaProducerTemplate のコンストラクター

ReactiveKafkaProducerTemplate(SenderOptions<K, V>) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaProducerTemplate のコンストラクター

ReactiveKafkaProducerTemplate(SenderOptions<K, V>, RecordMessageConverter) - クラス org.springframework.kafka.core.reactive. ReactiveKafkaProducerTemplate のコンストラクター

receive() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

receive(String, int, long) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

デフォルトのポーリングタイムアウト（5 秒）で単一のレコードを受信します。

receive(String, int, long, Duration) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

単一のレコードを受け取ります。

receive(String, int, long, Duration) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

receive(Collection<TopicPartitionOffset>) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

デフォルトのポーリングタイムアウト（5 秒）で複数のレコードを受信します。

receive(Collection<TopicPartitionOffset>, Duration) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

複数のレコードを受信します。

receive(Collection<TopicPartitionOffset>, Duration) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

receiveAtMostOnce() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

receiveAutoAck() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

receiveBatch() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

RECEIVED - Static variable in class org.springframework.kafka.support.KafkaHeaders

'received' 値を含む Kafka ヘッダーのプレフィックス。

RECEIVED_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders

受信したメッセージのレコードキーを含むヘッダー。

RECEIVED_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders

受信したメッセージのトピックパーティションを含むヘッダー。

RECEIVED_TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders

コンシューマーレコードのタイムスタンプを保持するためのヘッダー。

RECEIVED_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

メッセージの受信元のトピックを含むヘッダー。

receiveExactlyOnce(TransactionManager) - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

一度だけの配信セマンティクスに使用できるコンシューマーレコードバッチの Flux を返します。

RECORD - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

各レコードがリスナーによって処理された後、オフセットをコミットします。

RECORD_METADATA - Static variable in class org.springframework.kafka.support.KafkaHeaders

トピックへの送信が成功した後の RecordMetadata オブジェクトを含むヘッダー。

RecordFilterStrategy< K , V > - Interface in org.springframework.kafka.listener.adapter

このインターフェースの実装は、メッセージリスナーに配信されようとしているレコードを配信する代わりに破棄する必要があることを通知できます。

RecordInterceptor< K , V > - Interface in org.springframework.kafka.listener

リスナーを呼び出す前後にリスナーコンテナーによって呼び出される ConsumerRecord のインターセプター。

RecordMessageConverter - Interface in org.springframework.kafka.support.converter

Kafka 固有の Message コンバーター戦略。

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

構成可能な HandlerAdapter を呼び出す MessageListener アダプター。リスナーが個々のメッセージを受信するようにファクトリが構成されている場合に使用されます。

RecordMessagingMessageListenerAdapter(Object, Method) - クラス org.springframework.kafka.listener.adapter. RecordMessagingMessageListenerAdapter のコンストラクター

RecordMessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - クラス org.springframework.kafka.listener.adapter. RecordMessagingMessageListenerAdapter のコンストラクター

recordsToString(ConsumerRecords<?, ?>) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

レコードを topic-part@offset のコンマ区切りの文字列として表します。

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

失敗したレコードが正常に回復した後に呼び出されます。

recovered(ConsumerRecord<?, ?>, Exception, MessageListenerContainer, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。RecoveryStrategy

レコードが正常に回復されたためにスキップする必要がある場合は、true を返します。

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

失敗したレコードが正常に回復した後に呼び出されます。

RecoveringDeserializationExceptionHandler - org.springframework.kafka.streams のクラス

ConsumerRecordRecoverer を呼び出す DeserializationExceptionHandler。

RecoveringDeserializationExceptionHandler() - クラス org.springframework.kafka.streams. RecoveringDeserializationExceptionHandler のコンストラクター

RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer) - クラス org.springframework.kafka.streams. RecoveringDeserializationExceptionHandler のコンストラクター

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

回復の試みが失敗した後に呼び出されます。

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

回復の試みが失敗した後に呼び出されます。

RecoveryStrategy - Interface in org.springframework.kafka.listener

レコードをスキップする必要があるかどうかを判断するために呼び出されます。

registerAllEndpoints() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - クラス org.springframework.kafka.annotation のメソッド。KafkaBootstrapConfiguration

registerDestinationTopic(String, String, DestinationTopic.Properties, DestinationTopicProcessor.Context) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicProcessor

registerDestinationTopic(String, String, DestinationTopic.Properties, DestinationTopicProcessor.Context) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicProcessor

宛先トピックを登録します。

registerEndpoint(KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

デフォルトの KafkaListenerContainerFactory を使用して新しい KafkaListenerEndpoint を登録し、基になるコンテナーを作成します。

registerEndpoint(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

基になるコンテナーの作成に使用する KafkaListenerContainerFactory と一緒に新しい KafkaListenerEndpoint を登録します。

registerHints(RuntimeHints, ClassLoader) - クラス org.springframework.kafka.aot のメソッド。KafkaRuntimeHints

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

指定された KafkaListenerEndpoint のメッセージリスナーコンテナーを作成します。

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>, boolean) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

指定された KafkaListenerEndpoint のメッセージリスナーコンテナーを作成します。

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

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractDelegatingMessageListenerAdapter

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

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

任意の時間にシークするときに使用するコールバックを登録します。

relativeToCurrent() - Element in annotation interface org.springframework.kafka.annotation.PartitionOffset

デフォルトでは、正の PartitionOffset.initialOffset() は絶対値であり、負の値は現在のトピックの終わりを基準にしています。

releaseResources(KafkaResourceHolder<K, V>) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils

releaseSuffix(String, String) - クラス org.springframework.kafka.core のメソッド。DefaultTransactionIdSuffixStrategy

releaseSuffix(String, String) - インターフェース org.springframework.kafka.core のメソッド。TransactionIdSuffixStrategy

トランザクションプロデューサーのサフィックスを解放します。

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

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

removeClassification(Class<? extends Exception>) - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier

構成済みリストから例外型を削除します。

removeClassification(Class<? extends Exception>) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

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

指定されたキーを構成マップから削除します。

removeConfig(String) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

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

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

指定されたキーを構成マップから削除します。

removeContainer(MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。ContainerGroup

グループからコンテナーを削除します。

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

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

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

removeDelegate(ProducerListener<K, V>) - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener

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

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

型情報ヘッダーを削除します。

removeListener(StreamsBuilderFactoryBean.Listener) - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean

リスナーを削除します。

removeListener(ConsumerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

リスナーを削除します。

removeListener(ConsumerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

リスナーを削除します。

removeListener(ProducerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

リスナーを削除します。

removeListener(ProducerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

リスナーを削除します。

removeNotRetryableException(Class<? extends Exception>) - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

構成済みリストから例外型を削除します。

removePostProcessor(ConsumerPostProcessor<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

ポストプロセッサーを取り外します。

removePostProcessor(ConsumerPostProcessor<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

removePostProcessor(ProducerPostProcessor<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

removePostProcessor(ProducerPostProcessor<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

ポストプロセッサーを取り外します。

removeProducer(DefaultKafkaProducerFactory.CloseSafeProducer<K, V>, Duration) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

存在する場合は、単一の共有プロデューサーとスレッドバインドインスタンスを削除します。

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

replicas(int) - クラス org.springframework.kafka.config のメソッド。TopicBuilder

レプリカの数を設定します（デフォルトブローカー 'default.replication.factor' ）。

replicasAssignments(Map<Integer, List<Integer>>) - クラス org.springframework.kafka.config のメソッド。TopicBuilder

レプリカの割り当てを設定します。

replicationFactor() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

自動的に作成されたトピックの複製係数。

REPLY_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders

応答を送信するパーティション番号を含むヘッダー。

REPLY_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

デフォルトの返信トピックを含むヘッダー。

ReplyExpressionRoot(Object, Object, Object) - Constructor for record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

ReplyExpressionRoot レコードクラスのインスタンスを作成します。

ReplyHeadersConfigurer - Interface in org.springframework.kafka.listener.adapter

応答メッセージに設定するヘッダーがある場合は、それを構成するための戦略。

ReplyingKafkaOperations< K , V , R > - Interface in org.springframework.kafka.requestreply

リクエスト / 応答操作。

ReplyingKafkaTemplate< K , V , R > - Class in org.springframework.kafka.requestreply

リクエスト / 応答セマンティクスを実装する KafkaTemplate。

ReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, R>) - クラス org.springframework.kafka.requestreply. ReplyingKafkaTemplate のコンストラクター

ReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, R>, boolean) - クラス org.springframework.kafka.requestreply. ReplyingKafkaTemplate のコンストラクター

request() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

request レコードコンポーネントの値を返します。

RequestReplyFuture< K , V , R > - Class in org.springframework.kafka.requestreply

リクエスト / 応答用の CompletableFutureSE。

RequestReplyFuture() - クラス org.springframework.kafka.requestreply. RequestReplyFuture のコンストラクター

RequestReplyMessageFuture< K , V > - Class in org.springframework.kafka.requestreply

Message 応答の聞き取り可能な未来。

RequestReplyTypedMessageFuture< K , V , P > - Class in org.springframework.kafka.requestreply

特定のペイロード型で応答する Message のリッスン可能な未来。

REQUIRED - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag

必須 - 成功するには LoginModule が必要です。

REQUISITE - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag

必要条件 - 成功するには LoginModule が必要です。

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

Producer (s) を閉じ、トランザクション Producer (s) のキャッシュをクリアします。

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

サポートされている場合は、提供時の状態をリセットします。

resolveArgument(MethodParameter, Message<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。ContinuationHandlerMethodArgumentResolver

resolveArgument(MethodParameter, Message<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaNullAwarePayloadArgumentResolver

resolveBean(BeanFactory) - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMethod

resolveDestinationTopic(String, String, Integer, Exception, long) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver

resolveDestinationTopic(String, String, Integer, Exception, long) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicResolver

失敗したメッセージの宛先トピックを解決します。

resolveParameter(ParameterContext, ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。EmbeddedKafkaCondition

resolveTopicPartition(ConsumerRecord<?, ?>, DestinationTopic) - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

元のレコードを転送する必要がある TopicPartition を作成して返します。

resolveType(String, byte[], Headers) - インターフェース org.springframework.kafka.support.serializer のメソッド。JsonTypeResolver

型を決定します。

restart(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

result() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

result レコードコンポーネントの値を返します。

result() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

result レコードコンポーネントの値を返します。

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

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

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

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

一時停止している場合は、次の poll() の後にこのコンテナーを再開します。

resume(String) - クラス org.springframework.kafka.listener のメソッド。ListenerContainerPauseService

指定された ID でリスナーコンテナーを再開します。

resume(TopicPartition...) - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

resume(MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。ListenerContainerPauseService

リスナーコンテナーを再開します。

resumePartition(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

resumePartition(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer

resumePartition(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer

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

次の poll() の後で、一時停止している場合は、このパーティションを再開します。

retrieveHeader(Headers, String) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

retrieveHeaderAsString(Headers, String) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

retrieveQueryableStore(String, QueryableStoreType<T>) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsInteractiveQueryService

アプリケーションで作成された名前でクエリ可能なストアを取得して返します。

RETRY_TOPIC_CONFIGURER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

内部管理された再試行トピック構成プログラムの Bean 名。

RetryableTopic - Annotation Interface in org.springframework.kafka.annotation

KafkaListener アノテーション付きリスナーの再試行および dlt トピックを作成するためのアノテーション。

RetryableTopicAnnotationProcessor - org.springframework.kafka.annotation のクラス

提供された RetryableTopic アノテーションを処理して、RetryTopicConfiguration を返します。

RetryableTopicAnnotationProcessor(BeanFactory) - クラス org.springframework.kafka.annotation. RetryableTopicAnnotationProcessor のコンストラクター

提供されたパラメーターとデフォルトのリゾルバーである式コンテキストを使用してインスタンスを構築します。

RetryableTopicAnnotationProcessor(BeanFactory, BeanExpressionResolver, BeanExpressionContext) - クラス org.springframework.kafka.annotation. RetryableTopicAnnotationProcessor のコンストラクター

提供されたパラメーターを使用してインスタンスを構築します。

retryBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable, BackOff, CommonErrorHandler, BiConsumer<ConsumerRecords<?, ?>, Exception>, LogAccessor, KafkaException.Level, List<RetryListener>, BinaryExceptionClassifier, boolean) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

コンシューマーを一時停止して完全なバッチを再試行し、ループでコンシューマーをポーリングし、次のバックオフを待ってから、リスナーを呼び出します。

RetryingDeserializer< T > - Class in org.springframework.kafka.support.serializer

一時的なエラーが発生した場合にデシリアライゼーションを再試行するために、デリゲートと RetryOperations で構成されたデシリアライザー。

RetryingDeserializer(Deserializer<T>, RetryOperations) - クラス org.springframework.kafka.support.serializer. RetryingDeserializer のコンストラクター

RetryListener - Interface in org.springframework.kafka.listener

再試行アクティビティのリスナー。

retryOn(Class<? extends Exception>...) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport.BlockingRetriesConfigurer

ブロッキング再試行メカニズムによって再試行される例外を設定します。

retryOn(Class<? extends Throwable>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

提供された ThrowableSE で再試行するように動作を構成します。

retryOn(List<Class<? extends Throwable>>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

提供された ThrowableSE で再試行するように動作を構成します。

RetryTopicBeanNames - org.springframework.kafka.retrytopic のクラス

ノンブロッキングトピックベースの遅延再試行機能の Bean 名。

RetryTopicComponentFactory - org.springframework.kafka.retrytopic のクラス

RetryTopicConfigurationSupport で使用されるコンポーネントインスタンスを提供します。

RetryTopicComponentFactory() - クラス org.springframework.kafka.retrytopic. RetryTopicComponentFactory のコンストラクター

RetryTopicConfiguration - org.springframework.kafka.retrytopic のクラス

再試行可能なトピック用に提供された構成が含まれています。

RetryTopicConfigurationBuilder - org.springframework.kafka.retrytopic のクラス

RetryTopicConfiguration インスタンスを作成するためのビルダークラス。

RetryTopicConfigurationBuilder() - クラス org.springframework.kafka.retrytopic. RetryTopicConfigurationBuilder のコンストラクター

RetryTopicConfigurationProvider - org.springframework.kafka.annotation のクラス

RetryableTopic アノテーションから、またはアノテーションが利用できない場合は Bean コンテナーからインスタンスを作成して、RetryTopicConfiguration のインスタンスを提供しようとします。

RetryTopicConfigurationProvider(BeanFactory) - クラス org.springframework.kafka.annotation. RetryTopicConfigurationProvider のコンストラクター

提供されている Bean ファクトリとデフォルトのリゾルバーおよび Bean 式コンテキストを使用してインスタンスを構築します。

RetryTopicConfigurationProvider(BeanFactory, BeanExpressionResolver, BeanExpressionContext) - クラス org.springframework.kafka.annotation. RetryTopicConfigurationProvider のコンストラクター

提供されたパラメーターを使用してインスタンスを構築します。

RetryTopicConfigurationSupport - org.springframework.kafka.retrytopic のクラス

これは、ノンブロッキングのトピックベースの遅延再試行機能の背後にある構成を提供するメインクラスです。

RetryTopicConfigurationSupport() - クラス org.springframework.kafka.retrytopic. RetryTopicConfigurationSupport のコンストラクター

RetryTopicConfigurationSupport.BlockingRetriesConfigurer - org.springframework.kafka.retrytopic のクラス

ノンブロッキングで使用されるブロッキング再試行を構成します。

RetryTopicConfigurationSupport.CustomizersConfigurer - org.springframework.kafka.retrytopic のクラス

トピックの再試行機能によってインスタンス化されたコンポーネントのカスタマイザーを構成します。

retryTopicConfigurer(KafkaConsumerBackoffManager, DestinationTopicResolver, ObjectProvider<RetryTopicComponentFactory>, BeanFactory) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport

対応する RetryTopicConfiguration を持つ KafkaListenerEndpoint インスタンスの再試行トピックを構成するためのグローバル RetryTopicConfigurer を返します。

retryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryConfigurer, ListenerContainerFactoryResolver, RetryTopicNamesProviderFactory) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

適切な RetryTopicConfiguration を処理することにより、特定の KafkaListenerEndpoint のノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能する RetryTopicConfigurer を作成します。

RetryTopicConfigurer - org.springframework.kafka.retrytopic のクラス

メインエンドポイントと提供された構成に基づいてメイン、再試行、DLT トピックを構成し、順序の保証を犠牲にしてノンブロッキング方式で分散再試行 /DLT パターンを実現します。

RetryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryResolver, ListenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory) - クラス org.springframework.kafka.retrytopic. RetryTopicConfigurer のコンストラクター

提供されたプロパティでインスタンスを作成します。

RetryTopicConfigurer.EndpointProcessor - org.springframework.kafka.retrytopic のインターフェース

RetryTopicConstants - org.springframework.kafka.retrytopic のクラス

RetryTopic 機能の定数。

RetryTopicConstants() - クラス org.springframework.kafka.retrytopic. RetryTopicConstants のコンストラクター

RetryTopicHeaders - org.springframework.kafka.retrytopic のクラス

転送されたメッセージで使用されるヘッダーが含まれます。

RetryTopicHeaders() - クラス org.springframework.kafka.retrytopic. RetryTopicHeaders のコンストラクター

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

再試行トピックの KafkaListenerEndpoint のプロパティ名を提供するために使用される RetryTopicNamesProviderFactory インスタンスを作成します。

RetryTopicNamesProviderFactory - Interface in org.springframework.kafka.retrytopic

再試行およびデッドレタートピックに関連する命名を処理します。

RetryTopicNamesProviderFactory.RetryTopicNamesProvider - org.springframework.kafka.retrytopic のインターフェース

RetryTopicSchedulerWrapper - org.springframework.kafka.retrytopic のクラス

再試行トピックのためにパーティションが一時停止されたときにコンテナーの再開をスケジュールするために使用する TaskScheduler のラッパークラス。

RetryTopicSchedulerWrapper(TaskScheduler) - クラス org.springframework.kafka.retrytopic. RetryTopicSchedulerWrapper のコンストラクター

提供されたスケジューラーのラッパーを作成します。

retryTopicSuffix() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

再試行トピックを生成するためにメイントピックに追加されるサフィックス。

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

再試行トピックに追加するサフィックスを構成します。

returnTypeMessageOrCollectionOf(Method) - Static method in class org.springframework.kafka.support.KafkaUtils

メソッドの戻り値の型が Message または Collection<Message<?>> の場合は true を返します。

revertLevels(String, JUnitUtils.LevelsContainer) - Static method in class org.springframework.kafka.test.utils.JUnitUtils

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

RoutingKafkaTemplate - org.springframework.kafka.core のクラス

トピック名に基づいてメッセージをルーティングする KafkaTemplate。

RoutingKafkaTemplate(Map<Pattern, ProducerFactory<Object, Object>>) - クラス org.springframework.kafka.core. RoutingKafkaTemplate のコンストラクター

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