Kinesis クライアントライブラリの使用 - Amazon Kinesis Data Streams

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Kinesis クライアントライブラリの使用

Kinesis Client Library とは

Kinesis Client Library (KCL) は、Amazon Kinesis Data Streams からのデータの消費と処理のプロセスを簡素化するために設計されたスタンドアロンの Java ソフトウェアライブラリです。KCL は、分散コンピューティングに関連する複雑なタスクの多くを処理し、デベロッパーがデータ処理のビジネスロジックの実装に集中できるようにします。複数のワーカー間での負荷分散、ワーカーの障害への対応、処理されたレコードのチェックポイント、ストリーム内のシャード数の変化への対応などのアクティビティを管理します。

KCL は、基盤となるライブラリの新しいバージョン、セキュリティの改善、バグ修正を組み込むために頻繁に更新されます。最新バージョンの を使用することをお勧めしますKCL。KCL 最新バージョンを検索するには、KCL「Github 」を参照してください。

重要

KCL は Java ライブラリです。Java 以外の言語のサポートは、 MultiLangDaemon. MultiLangDaemon interacts という Java ベースのデーモンを使用して、 STDINおよび 経由でKCLアプリケーションと連携しますSTDOUT。 MultiLangDaemon の の詳細については GitHub、「」を参照してくださいJava 以外の言語で KCLを使用してコンシューマーを開発する

KCL 主な機能と利点

以下は、 の主な機能とそれに関連する利点ですKCL。

  • スケーラビリティ : KCL 複数のワーカーに処理負荷を分散することで、アプリケーションが動的にスケーリングできるようにします。ロードの再分散を気にすることなく、アプリケーションを手動または自動スケーリングでスケールインまたはスケールアウトできます。

  • ロードバランシング : は、利用可能なワーカー間で処理負荷KCLを自動的にバランスさせ、ワーカー間で作業を均等に分散します。

  • チェックポイント: 処理されたレコードのチェックポイントKCLを管理し、アプリケーションが最後に正常に処理された位置から処理を再開できるようにします。

  • フォールトトレランス: KCLは、障害耐性メカニズムを組み込み、個々のワーカーが失敗してもデータ処理が継続されるようにします。KCL は at-least-once配信も提供します。

  • ストリームレベルの変更の処理: データボリュームの変更によって発生する可能性のあるシャード分割とマージにKCL適応します。子シャードは、親シャードが完了しチェックポイントされた後にのみ処理されるようにすることで、順序を維持します。

  • モニタリング: は、Amazon とKCL統合してコンシューマーレベルのモニタリング CloudWatch を行います。

  • 多言語サポート: は Java をKCLネイティブにサポートし、 を通じて複数の非 Java プログラミング言語を有効にします MultiLangDaemon。