翻訳準備中 — 韓国語の原文を表示しています。
Amazon Kinesis용 클라이언트 측 분산 컨슈머 그룹 클라이언트
中辛 の解説
Go로 작성된 Kinesis 클라이언트 라이브러리로, DynamoDB를 상태 저장소로 사용합니다. 여러 스트림을 동시에 소비하고, 샤드 범위를 자동으로 분배하며, 클라이언트 변화 시 리밸런싱합니다. 난이도는 중상(3/5)이며, AWS 계정 간 크로스 어카운트 접근도 지원하고, 즉시 사용 가능한 Go 코드 예제가 제공됩니다.
이런 레포예요
이럴 때 쓰면 좋아요
- 여러 애플리케이션 인스턴스가 Kinesis 스트림의 데이터를 균형있게 소비해야 하는 경우
- 실시간 로그 또는 이벤트 스트림을 여러 서버에서 처리할 때
- Kinesis 샤드 재조정이나 인스턴스 스케일링 중에도 메시지 손실 없이 처리해야 할 때
핵심 기능
대안 대비 차별점
중앙 조정자 없이 DynamoDB만을 이용해 클라이언트 간 동기화를 수행하므로, 별도의 조정 서비스 운영 오버헤드를 제거할 수 있습니다.
食べた人たち
実際に使ってみた人の記録です — 一言も完走の記録も、確認のうえで公開しています。
このリポジトリの作り方
はじめてですか？ むずかしくありません — 上から順にたどれば、自分の環境で動かして味見できます。
준비물
- AWS 계정 및 IAM 권한 (Kinesis, DynamoDB)
- DynamoDB 상태 저장소 테이블 사전 생성
- Go 1.11 이상
すぐ動かしてみるGo
ギット飯がリポジトリの構成を確認して組み立てた実行コマンドです。ターミナルに貼り付ければ、取得から実行までまとめて進みます。
git clone --depth 1 https://github.com/daangn/kinesumer.git && cd kinesumer && go run .
コードは自分の環境で動きます — はじめて見るリポジトリなら、中身にひととおり目を通してから実行するのがおすすめです。
README가 안내하는 자세한 단계 보기
- DynamoDB 상태 저장소 테이블 생성
LSI 스키마에 따라 DynamoDB 테이블을 생성합니다.
- Go 모듈에 Kinesumer 추가
go get github.com/daangn/kinesumer
- 클라이언트 초기화
client, err := kinesumer.NewKinesumer(
&kinesumer.Config{
App: "myapp",
KinesisRegion: "ap-northeast-2",
DynamoDBRegion: "ap-northeast-2",
DynamoDBTable: "kinesumer-state-store",
ScanLimit: 1500,
ScanTimeout: 2 * time.Second,
},
)
if err != nil {
panic(err)
}
- 에러 채널 모니터링
go func() {
for err := range client.Errors() {
// 에러 처리
}
}()
- 스트림에서 메시지 소비
records, err := client.Consume([]string{"stream1", "stream2"})
if err != nil {
panic(err)
}
for record := range records {
fmt.Printf("record: %v\n", record)
}
ギット飯トライで味見
入れるのが面倒で少し不安だったなら — 安全スキャンからインストールまで、ターミナル一行で終わります。
ターミナルに貼り付ければ、ギット飯の安全スキャン → 隔離フォルダへ clone → インストール → 実行方法の案内まで自動です。はじめてでも大丈夫 — この一行だけです。
npx gitbap-try daangn/kinesumer
Node.js さえあれば、インストールなしで動きます · ギット飯トライとは？ →
スター推移 · 7日
使いやすさ · まねしやすいか
- ゆるいライセンス
- テストあり
- サンプル集
- 最近の更新
- AGENTS.md
- llms.txt
- テンプレート
更新の情報なし · 2021 年に作成
「백엔드·DB」 こういうリポジトリを毎週受け取りませんか？
毎週月曜の朝、選んだ一膳だけ。広告なし · いつでも解除。
自分のリポジトリですか？ README にギット飯バッジを貼る
[](https://www.gitbap.com/r/daangn/kinesumer)Claude からそのまま使う — ギット飯のつなぎ方
ギット飯を Claude につなぐと、こうしたリポジトリを Claude・Cursor・Codex から直接さがして試せます。
Claude の設定 → コネクタにこのアドレスを貼り付け。
https://www.gitbap.com/api/mcpプラグインを入れると /gitbap-trending·/gitbap-try のスラッシュコマンドで、その場でリポジトリを試せます。Claude Code で下の 2 行を順に実行してください。
/plugin marketplace add jakeparkcolde/gitbap-cowork/plugin install gitbap-cowork@gitbapAI が README をもとに要約しました · 原文を見る