パッケージの使用
org.springframework.kafka.config
org.springframework.kafka.config を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
kafka 構成のパッケージ
再試行可能なトピック処理用のパッケージ。
Kafka ストリームに関連するクラスのパッケージ。
- クラス説明
KafkaListenerEndpointをKafkaListenerEndpointRegistryに登録するためのヘルパー Bean。登録されたエンドポイントに必要なMessageListenerContainerインスタンスを作成します。StreamsBuilderプロパティのラッパー。このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供するKafkaListenerEndpoint。 - クラス説明Spring の基本コンテナー実装用の基本
KafkaListenerContainerFactory。Kafka リスナーエンドポイントの基本モデル。コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。MessageListenerContainerのファクトリ。Kafka リスナーエンドポイントのモデル。登録されたエンドポイントに必要なMessageListenerContainerインスタンスを作成します。StreamsBuilderプロパティのラッパー。KafkaStreamsを直接構成するために使用できるコールバックインターフェース。StreamsBuilderやTopologyなどのインフラストラクチャコンポーネント用のカスタマイザ。このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供するKafkaListenerEndpoint。KafkaStreamsが追加または削除されるたびに呼び出されます。NewTopicのビルダー。 - クラス説明
MessageListenerContainerのファクトリ。Kafka リスナーエンドポイントのモデル。KafkaListenerEndpointをKafkaListenerEndpointRegistryに登録するためのヘルパー Bean。このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供するKafkaListenerEndpoint。 - クラス説明
KafkaStreamsが追加または削除されるたびに呼び出されます。