Amazon Kinesis Adapter は、Amazon Kinesis Data Streams を Apache Kinesis Client Library (KCL) で利用するためのプラグインです。
通常の Kinesis Data Streams と異なり、Kinesis Adapter は Amazon DynamoDB Streams のデータストリームを Kinesis ストリームのように扱えるようにするために提供されています。
Kinesis Adapter の主な特徴
- DynamoDB Streams を Kinesis Streams 互換の API で利用可能
- Kinesis クライアント (KCL) を使って、DynamoDB Streams のデータをストリーム処理できます。
- KCL のメリットを活用
- チェックポイント管理
- シャードの動的管理
- 並行処理の最適化 など
Kinesis Data Streams との違い
| 項目 | Kinesis Data Streams | Kinesis Adapter |
|---|---|---|
| データソース | 独自のデータストリーム | DynamoDB Streams |
| API | Kinesis API | Kinesis API (互換) |
| 用途 | ストリームデータの処理 (IoT, ログ解析, リアルタイム分析) | DynamoDB の変更データ処理 |
| KCL サポート | ネイティブサポート | Kinesis Adapter 経由 |
使用例
例えば、DynamoDB にレコードが追加・更新・削除された際に、それを リアルタイムで処理したい場合 に Kinesis Adapter を活用できます。
Kinesis Adapter を利用することで、DynamoDB Streams のデータを Kinesis Streams のように扱い、KCL を用いて効率的に処理できます。
