パッケージの使用
org.springframework.kafka.core
org.springframework.kafka.core を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
kafka コアコンポーネントのパッケージ
kafka リスナーのためのパッケージ
リスナーを適応させるためのクラスを提供します。
MockConsumer および MockProducer の使用をサポートするクラスを提供します。
リクエスト / 応答セマンティクスのクラスを提供します。
再試行可能なトピック処理用のパッケージ。
Kafka ストリームに関連するクラスのパッケージ。
トランザクションに関連するクラスを提供します。
- クラス説明
KafkaStreams.cleanUp()の実行時刻を指定します。Consumerインスタンスを生成する戦略。高レベルの操作を実行するためのテンプレート。 - org.springframework.kafka.core で使用されている org.springframework.kafka.core のクラスクラス説明
Consumerインスタンスを生成する戦略。コンシューマーが追加または削除されるたびに呼び出されます。新しく作成されたコンシューマーで後処理を実行するために、コンシューマーファクトリによって呼び出されます。デリゲートのラッパークラス。アプリケーションコンテキストで定義されたトピックを作成するためにAdminに委譲する管理者。AdminClientをラップする多くの便利なメソッドを提供します。KafkaClientMetricsを管理するための抽象クラス。CompletableFutureSE を返す基本的な Kafka オペレーション契約。KafkaOperationsで任意の操作を実行するためのコールバック。Producerで任意の操作を実行するためのコールバック。コンシューマー / プロデューサー / 管理者クリエーターの基本クラス。Kafka リソースホルダー、Kafka プロデューサーをラップします。高レベルの操作を実行するためのテンプレート。Producerインスタンスを生成する戦略。プロデューサーが追加または削除されるたびに呼び出されます。新しく作成されたプロデューサーに対して後処理を実行するために、プロデューサーファクトリによって呼び出されます。トランザクションプロデューサーサフィックスを管理するための戦略。 - クラス説明
Consumerインスタンスを生成する戦略。アプリケーションコンテキストで定義されたトピックを作成するためにAdminに委譲する管理者。CompletableFutureSE を返す基本的な Kafka オペレーション契約。 - org.springframework.kafka.mock で使用されている org.springframework.kafka.core のクラス