Spring for Apache Kafka

サポート対象

NRIのOpenStandiaが提供するSpring for Apache Kafka最新情報

バージョンアップ情報
Spring for Apache Kafka情報

バージョンアップ情報

一覧を見る

Spring for Apache Kafka情報

Spring for Apache Kafkaとは
主な特徴
動作環境
Spring for Apache Kafkaのライセンス
参考情報
オープンソース年間サポートサービス

Spring for Apache Kafkaとは

Spring for Apache Kafka(SpringKafka)プロジェクトは、SpringのコアコンセプトをKafkaベースのメッセージングソリューションの開発に適用したものです。
メッセージを送信するためのハイレベルな抽象化テンプレートとしてKafkaTemplateを提供しています。また、@KafkaListenerアノテーションによるメッセージ駆動型POJO（Plain Old Java Object）をサポートし、シンプルなSpringテンプレートプログラミングモデルを提供します。

主な特徴

Spring for Apache Kafkaの特徴として、以下のような機能を備えています。

KafkaTemplate	Kafkaにメッセージを送信するためのメソッドを提供します。型引数を指定する必要があり、それぞれ送信するデータのKeyとvalueの型を指定します。
KafkaMessage ListenerContainer	単一のスレッド上のすべてのトピックまたはパーティションからすべてのメッセージを受信します。
ConcurrentMessage ListenerContainer	concurrency に基づいて1つ以上の KafkaMessageListenerContainer を作成して、メッセージを受信するマルチスレッドのリスナー。
@KafkaListener アノテーション	POJOベースのConsumerを設定・実装できるようにします。これを利用する為には、ConsumerFactoryとKafkaListenerContainerFactoryを設定する必要があります。また、これを有効にするにはさらに構成クラスで @EnableKafkaアノテーションを付与する必要があります。これにより MessageListenerContainerがDIコンテナに登録され、Kafka Consumerが自動で設定されます。
Micrometer	リスナーコンテナーやテンプレート、ProducerやConsumerのトランザクション制御を行います。これを利用するためには、DefaultKafkaProducerFactoryに transactionIdPrefixを提供することにより有効になります。
KafkaTransactionManager	リスナーコンテナーやテンプレートのパフォーマンス、ProducerやConsumerのmetricsを収集することが出来ます。
Kafka Streamsサポート	Kafka Streamsのサポートを提供します。 Springアプリケーションから使用するには、kafka-streams jarがクラスパスに存在する必要があります。これは Spring for Apache Kafkaプロジェクトのオプションであるため、明示的にダウンロードする必要があります。
アプリケーションテスト	組み込みkafkaサーバーやJUnit、テスト用Utilなどのアプリケーションのテストに役立つ便利なユーティリティがいくつか含まれたspring-kafka-test jarを提供しています。