Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

7.8. メッセージヘッダー

Expand
名前説明

CamelAwsKinesisSequenceNumber (common)

定数: SEQUENCE_NUMBER

PutRecord syntax で定義されたレコードのシーケンス番号。

CamelAwsKinesisApproximateArrivalTimestamp (common)

Constant: APPROX_ARRIVAL_TIME

AWS がレコードの到着時間として割り当てた時間。

CamelAwsKinesisPartitionKey (common)

定数: PARTITION_KEY

データレコードが割り当てられているストリーム内のシャードを識別します。

CamelMessageTimestamp (common)

Constant: MESSAGE_TIMESTAMP

メッセージのタイムスタンプ。

CamelAwsKinesisShardId (common)

Constant: SHARD_ID

データレコードが配置されたシャードのシャード ID。

7.8.1. AmazonKinesis の設定
リンクのコピー

次にamazonKinesisClient URI オプションで KinesisClient を参照する必要があります。 

from("aws2-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
  .to("log:out?showAll=true");

7.8.2. AWS 認証情報の指定
リンクのコピー

新しい ClientConfiguration インスタンスを作成するときのデフォルトである DefaultAWSCredentialsProviderChain を使用して認証情報を取得することを推奨しますが、createClient (…) を呼び出すときに別の AWSCredentialsProvider を指定できます。

7.8.3. AWS Kinesis KCL コンシューマー
リンクのコピー

このコンポーネントは、Kinesis Data Stream から消費するための KCL (Kinesis クライアントライブラリー) もサポートします。この機能を有効にするには、エンドポイントで 2 つの異なるパラメーターを設定します。 

from("aws2-kinesis://mykinesisstream?asyncClient=true&useDefaultCredentialsProvider=true&useKclConsumers=true")
  .to("log:out?showAll=true");

この機能により、KCL、DynamoDB テーブル、CloudWatch アラームを組み合わせて使用して、シャードイテレーションのチェックポイントを自動的に作成できるようになります。これは、AWS 認証情報を使用するだけですぐに使用できます。

注記

KCL を使用する AWS Kinesis コンシューマーの起動には約 60 - 70 秒かかります。

Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2026 Red Hatトップに戻る