クラスの使用
org.springframework.kafka.config.MethodKafkaListenerEndpoint
MethodKafkaListenerEndpoint を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
kafka 構成のパッケージ
再試行可能なトピック処理用のパッケージ。
org.springframework.kafka.annotation 内の MethodKafkaListenerEndpoint 使用
型 MethodKafkaListenerEndpoint のパラメーターを持つ org.springframework.kafka.annotation のメソッド修飾子と型メソッド説明protected void
KafkaListenerAnnotationBeanPostProcessor.processListener
(MethodKafkaListenerEndpoint<?, ?> endpoint, KafkaListener kafkaListener, ObjectSE bean, StringSE beanName, StringSE[] topics, TopicPartitionOffset[] tps) org.springframework.kafka.config 内の MethodKafkaListenerEndpoint 使用
org.springframework.kafka.retrytopic 内の MethodKafkaListenerEndpoint 使用
MethodKafkaListenerEndpoint 型の型パラメーターを持つ org.springframework.kafka.retrytopic のクラス修飾子と型インターフェース説明interface
EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,
?>> トピックの再試行機能でメイン、再試行、DLT エンドポイントをカスタマイズし、結果のトピック名を返します。型 MethodKafkaListenerEndpoint の引数を持つ型を返す org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> EndpointCustomizerFactory.addSuffixesAndMethod
(DestinationTopic.Properties properties) MethodKafkaListenerEndpoint の EndpointCustomizer を作成し、MultiMethodKafkaListenerEndpoint をサポートします。final EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> EndpointCustomizerFactory.createEndpointCustomizer()
protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> RetryTopicConfigurer.createEndpointCustomizer
(EndpointHandlerMethod endpointBeanMethod, DestinationTopic.Properties destinationTopicProperties) 型 MethodKafkaListenerEndpoint のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected CollectionSE<EndpointCustomizer.TopicNamesHolder>
EndpointCustomizerFactory.customizeAndRegisterTopics
(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint) protected EndpointHandlerMethod
RetryTopicConfigurer.getEndpointHandlerMethod
(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) default void
RetryTopicConfigurer.EndpointProcessor.process
(MethodKafkaListenerEndpoint<?, ?> listenerEndpoint) void
RetryTopicConfigurer.processMainAndRetryListeners
(RetryTopicConfigurer.EndpointProcessor endpointProcessor, MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, KafkaListenerEndpointRegistrar registrar, KafkaListenerContainerFactory<?> factory, StringSE defaultContainerFactoryBeanName) 再試行エンドポイントと dlt エンドポイントを作成および構成するためのエントリポイントと、対応する listenerContainer を作成するコンテナーファクトリ。