パッケージ org.springframework.kafka.annotation
@NonNullApi @NonNullFields パッケージ org.springframework.kafka.annotation
kafka アノテーションのパッケージ
- クラス説明DLT トピックメッセージを処理するメソッドを決定するためのアノテーション。
AbstractListenerContainerFactoryによってカバーで作成された Kafka リスナーのアノテーション付きエンドポイントを有効にします。ノンブロッキングトピックベースの遅延再試行機能を有効にします。デフォルトの Kafka Streams コンポーネントを有効にします。Spring の @KafkaListenerアノテーションを処理できるKafkaListenerAnnotationBeanPostProcessorBean を登録するImportBeanDefinitionRegistrarクラス。KafkaListenerでアノテーションが付けられたクラス内の Kafka メッセージリスナーのターゲットであるメソッドをマークするアノテーション。指定されたトピックで Kafka メッセージリスナーのターゲットとなるメソッドをマークするアノテーション。アノテーションのパラメーターに従って、KafkaListenerContainerFactoryによってカバーで作成された Kafka メッセージリスナーコンテナーによって呼び出される、KafkaListenerでアノテーションが付けられたメソッドを登録する Bean ポストプロセッサー。アノテーション属性の各セットを後処理します。可能な限り遅くKafkaBootstrapConfigurationをインポートするための最低次数のDeferredImportSelector実装。Spring によって実装されるオプションのインターフェース Bean が Kafka リスナーエンドポイントの構成方法をカスタマイズすることを望んでいます。いくつかのKafkaListenerアノテーションを集約するコンテナーアノテーション。KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAMEという名前のStreamsConfigがアプリケーションコンテキストに存在する場合、StreamsBuilderFactoryBeanを登録する@Configurationクラス。KafkaListenerにパーティション / 初期オフセット情報を追加するために使用されます。KafkaListenerアノテーション付きリスナーの再試行および dlt トピックを作成するためのアノテーション。提供されたRetryableTopicアノテーションを処理して、RetryTopicConfigurationを返します。RetryableTopicアノテーションから、またはアノテーションが利用できない場合は Bean コンテナーからインスタンスを作成して、RetryTopicConfigurationのインスタンスを提供しようとします。トピック / パーティション情報をKafkaListenerに追加するために使用されます。