クラスの使用
org.springframework.kafka.retrytopic.RetryTopicConfiguration
RetryTopicConfiguration を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
再試行可能なトピック処理用のパッケージ。
org.springframework.kafka.annotation 内の RetryTopicConfiguration 使用
修飾子と型メソッド説明RetryTopicConfigurationProvider.findRetryConfigurationFor(StringSE[] topics, MethodSE method, ClassSE<?> clazz, ObjectSE bean) 再試行トピック構成を見つけます。RetryTopicConfigurationProvider.findRetryConfigurationFor(StringSE[] topics, MethodSE method, ObjectSE bean) RetryableTopicAnnotationProcessor.processAnnotation(StringSE[] topics, ClassSE<?> clazz, RetryableTopic annotation, ObjectSE bean) RetryableTopicAnnotationProcessor.processAnnotation(StringSE[] topics, MethodSE method, RetryableTopic annotation, ObjectSE bean) org.springframework.kafka.retrytopic 内の RetryTopicConfiguration 使用
修飾子と型メソッド説明RetryTopicConfigurationBuilder.create(KafkaOperations<?, ?> sendToTopicKafkaTemplate) 提供されたテンプレートを使用してRetryTopicConfigurationを作成します。型 RetryTopicConfiguration のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected EndpointHandlerMethodRetryTopicConfigurer.getEndpointHandlerMethod(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) voidRetryTopicConfigurer.processMainAndRetryListeners(RetryTopicConfigurer.EndpointProcessor endpointProcessor, MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, KafkaListenerEndpointRegistrar registrar, KafkaListenerContainerFactory<?> factory, StringSE defaultContainerFactoryBeanName) 再試行および dlt エンドポイント、および対応する listenerContainer を作成するコンテナーファクトリを作成および構成するためのエントリポイント。