パッケージ org.springframework.kafka.core
@NonNullApi パッケージ org.springframework.kafka.core
kafka コアコンポーネントのパッケージ
- クラス説明サーバーの 2 つのリストを切り替えることができるブートストラップサーバーの
SupplierSE。KafkaStreams.cleanUp()の実行時刻を指定します。ConsumerFactory<K,V> Consumerインスタンスを生成する戦略。コンシューマーが追加または削除されるたびに呼び出されます。新しく作成されたコンシューマーで後処理を実行するために、コンシューマーファクトリによって呼び出されます。ConsumerFactory.createConsumer()呼び出しごとに、提供されたMapSEconfigsおよびオプションのDeserializerの新しいConsumerインスタンスを生成するConsumerFactory実装。デリゲートのラッパークラス。トランザクションプロデューサーサフィックスを管理するためのTransactionIdSuffixStrategy実装。アプリケーションコンテキストで定義されたトピックを作成するためにAdminClientに委譲する管理者。複数のトピックを単一の Bean として宣言するのを容易にするNewTopicのコレクションのラッパー。AdminClientをラップする多くの便利なメソッドを提供します。KafkaOperations<K,V> CompletableFutureSE を返す基本的な Kafka オペレーション 契約。KafkaOperationsで任意の操作を実行するためのコールバック。Producerで任意の操作を実行するためのコールバック。生産時の例外。コンシューマー / プロデューサー / 管理者クリエーターの基本クラス。KafkaResourceHolder<K,V> Kafka リソースホルダー、Kafka プロデューサーをラップします。KafkaTemplate<K,V> 高レベルの操作を実行するためのテンプレート。KafkaClientMetricsを管理するコンシューマーファクトリリスナー。KafkaClientMetricsを管理するプロデューサーファクトリリスナー。プロデューサーが利用できない場合の例外。ProducerFactory<K,V> Producerインスタンスを生成する戦略。プロデューサーが追加または削除されるたびに呼び出されます。Spring ベースの KafkaDefaultKafkaProducerFactoryを管理するためのヘルパークラス、特に特定の ProducerFactory のトランザクション Kafka リソースを取得するためのクラス。新しく作成されたプロデューサーに対して後処理を実行するために、プロデューサーファクトリによって呼び出されます。トピック名に基づいてメッセージをルーティングするKafkaTemplate。トランザクションプロデューサーサフィックスを管理するための戦略。