OSS探訪GitHubでログイン

Kafka producer・consumer・retry・transactionをSpring abstractionで統一する

スコアの見方

OSS規模スコアはStars・Watchers・Forks・Contributorsを対数圧縮して重み付けした現在の規模指標(上限なし)です。発掘スコアは現在のOSS規模スコアから発掘時点のOSS規模スコアを引いた値、更新ペースは直近30日Commit数、成長モメンタムは直近の観測期間におけるOSS規模スコア差、OSS健全度は取得できた更新状況・Community Health・Releaseの0〜100評価です。

Stars
2,513
主要言語
Java
ライセンス
Apache-2.0
リポジトリ最終更新
2026/10/06
ページ内ナビ

概要

Spring for Apache KafkaはApache Kafka clientをSpringらしいAPIで包むintegration libraryです。KafkaTemplate、@KafkaListener、listener container、error handler、transaction、non-blocking retry、Kafka Streams、test utility等を提供します。

特徴と向いている用途

公式資料に基づく紹介・実機未検証 · 内容確認日:

主な特徴

KafkaTemplateと@KafkaListenerでproduce/consumeを構成する

core moduleはKafkaTemplateによるsend/receive、@KafkaListener、single/multi-thread listener container、KafkaAdmin等を提供します。

出典:[2]

retry topic・transaction・test utilityをSpring lifecycleへ統合する

@RetryableTopicによるnon-blocking retryとdead-letter routing、KafkaTransactionManager、EmbeddedKafkaBrokerやJUnit support等が用意されています。

出典:[2]

向いている用途

Spring Boot/Kotlinのevent-driven backendでKafka運用を標準化したい場合に向く

producer/consumer factory、listener lifecycle、error handling、retry、transactionをSpring configurationへまとめたいserviceに適します。

出典:[2][1]

導入前の確認

retry・ack・transactionの組み合わせをmessage delivery policyとして設計する

listener container、AckMode、error handler、retry topic、transaction等の選択肢があるため、at-least-once処理、idempotency、DLT policyをapplication側で明確にしてください。

出典:[2]

4.1.1にはKafka header handlingのCVE修正が含まれる

v4.1.1ではretry_topic-original-timestamp/backoff timestamp headerのhardeningと、特定のjava.net typeをheader type mappingで制限するCVE修正に加え、retry中のrecord loss等のbug fixが含まれます。

出典:[3]

参考にした公式資料

  1. [1]Spring Kafka README(2026-10-06)
  2. [2]Spring Kafka module structure(2026-10-06)
  3. [3]Spring Kafka v4.1.1 release(2026-10-06)
編集部からの補足

Spring Boot/KotlinでKafka producer/consumerをSpringのconfiguration・error handlingへ統合したい場合に向きます。4.1.1にはheader handlingに関するCVE修正が含まれるため、旧版利用時はupgrade要否を確認してください。

3ステップで試す

  1. 1

    ソースを取得

    git clone --depth 1 https://github.com/spring-projects/spring-kafka.git
  2. 2

    リポジトリへ移動

    cd spring-kafka
  3. 3

    公式手順を確認

    READMEのInstallation / Quick Start / Getting Startedにある公式コマンドを続けて実行してください。

    find . -maxdepth 1 -iname 'README*' -exec sed -n '1,220p' {} \; -quit
公式READMEで確認

成長

成長の推移 · 直近30日

2,513 Stars

推移データを蓄積中です。

開発アクティビティ

直近90日・週次

Commit(直近30日)
61
Open PR
10

開発アクティビティを蓄積中です。

Built with

カテゴリとタグ

カテゴリ

GitHubデータ

GitHubのデータGitHubの詳細データを見る
Stars
2,513
Forks
1,771
Watchers
148
Open Issues
31
Contributors
274
所有者種別
Organization
主要言語
Java
ライセンス
Apache-2.0
リポジトリ最終更新
2026/10/06

このOSSの使い方や活用事例をMarkdownで投稿できます。管理者が承認した後に公開されます。

情報の誤りを報告

掲載内容に誤りや古い情報があればお知らせください。

このページを読んで、次に何をすればよいか分かりましたか?