OSS探訪
GitHubでログイン
GitHubで見る

Reader・Writerと低level Connを使い分けるpure Go Kafka client

OSS規模スコア 256.1OSS健全度 68更新ペース 0 Commit/30日
スコアの見方

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

Stars
8,638
主要言語
Go
ライセンス
MIT
リポジトリ最終更新
2026/04/23
ページ内ナビ

概要

kafka-goはGo向けのKafka client libraryです。低levelなConnに加え、consumer向けReaderとproducer向けWriterを提供し、Goのcontextや標準libraryに近いinterfaceでKafkaへ接続できます。

特徴と向いている用途

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

主な特徴

ReaderとWriterでconsumer/producer処理を高level APIとして組む

Readerはreconnectやoffset管理、contextによるcancel/timeoutを扱い、Writerはmessage publishを高level APIで構成できます。consumer group用途にも対応します。

出典：[2]

Connでpartition leaderやKafka protocolに近い操作へ降りる

ConnはKafka serverへのnetwork connectionをwrapし、partitionへのread/write、topic作成やmetadata取得等の低level操作を行うbuilding blockとして利用できます。

出典：[2]

向いている用途

cgo依存を避けつつGoらしいAPIでKafkaを扱いたいbackendに向く

Go serviceからKafka producer/consumerを実装し、context、Reader/Writer、pure Go dependencyを重視するevent-driven backendやdata pipelineに適します。

出典：[2]

導入前の確認

v0.4.51のgo.modはGo 1.23。broker feature対応はclient実装範囲を確認する

v0.4.51のgo.modはGo 1.23を指定します。READMEのKafka version記述は0.10.1.0〜2.7.1でのtestを基準にしており、それ以降のbrokerでも動作し得ますが新しいKafka APIが未実装の場合があります。利用broker versionでproducer/consumer group・SASL/TLS・error/retry pathを検証してください。

出典：[3][2][4]

参考にした公式資料

  1. [1]segmentio/kafka-go — GitHub repository(2026-10-06)
  2. [2]kafka-go v0.4.51 — README(2026-10-06)
  3. [3]kafka-go v0.4.51 — go.mod(2026-10-06)
  4. [4]kafka-go v0.4.51 release(2026-10-06)
  5. [5]kafka-go MIT license(2026-10-06)
編集部からの補足

Go標準libraryに近いAPI設計で、低level Connから高level Reader/Writerまで選べるKafka clientです。Kafka broker versionとclient実装のAPI対応範囲、consumer groupのcommit/rebalance、retry・timeoutをproduction条件で確認してください。

3ステップで試す

  1. 1

    ソースを取得

    git clone --depth 1 https://github.com/segmentio/kafka-go.git
  2. 2

    リポジトリへ移動

    cd kafka-go
  3. 3

    公式手順を確認

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

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

成長

成長の推移 · 直近30日

8,638 Stars

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

開発アクティビティ

直近90日・週次

Commit（直近30日）
0
Open PR
84

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

Built with

カテゴリとタグ

カテゴリ

タグ

GitHubデータ

GitHubのデータGitHubの詳細データを見る
GitHubで見る

GitHub Topics

  • kafka
  • golang
  • go
  • segment
  • kafka-client
  • consumer
  • producer
  • golang-library
  • golang-native
Stars
8,638
Forks
864
Watchers
86
Open Issues
182
Contributors
144
所有者種別
Organization
主要言語
Go
ライセンス
MIT
リポジトリ最終更新
2026/04/23
関連記事を投稿する

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

情報の誤りを報告

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

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