--- schema_version: "1" id: 4ca95ec460c0421d11c35eefd7ce390f3266b69525292db6380dd4dd888a93bc title: Amazon Kinesis Data Streams Connector 1.0 リファレンス collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/amazon-kinesis-connector/1.0/amazon-kinesis-connector-reference.md canonical_url: https://docs.mulesoft.com/jp/amazon-kinesis-connector/1.0/amazon-kinesis-connector-reference source_site: docs.mulesoft.com content_type: documentation content_hash: 97c3009da1bc8e4155544fc5034b29eaf417eb24cf70c2fe13c5bd8bcdf75b2b description: MuleSoft Documentation Site release: "1.0" latest: true --- # Amazon Kinesis Data Streams Connector 1.0 リファレンス
Amazon Kinesis Data Streams Connector では、バージョン 0.14.0 以降の Windows サポートが廃止された Kinesis Producer Library (KPL) を使用しているため、Windows はサポートされません。
## [](#設定)設定 * * * ### [](#Config)設定 コネクタの設定。この設定は、プロデューサーとコンシューマーの両方に使用できます。 #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

Kinesis Connection (Kinesis 接続)

この設定に指定する接続型。

x

Aggregation Enabled (集約有効化)

Boolean (ブール)

true​ に設定すると、このオプションによって複数のユーザーデータレコードが 1 つの Amazon Kinesis データレコードにまとめられます。

true

Response Timeout (応答タイムアウト)

Number (数値)

HTTP 要求の開始から応答が受信されるまで許容される最大合計時間。この時間を超えると、要求はタイムアウトします。

30

Request Timeout Unit (要求タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 値の時間単位。

SECONDS

Record Max Buffered Time (レコード最大バッファ時間)

Number (数値)

Amazon Kinesis データレコードが送信される前にバッファに費やす最大時間。他のバッファ制限によっては、この値よりも早くレコードを送信できます。

3

Record Max Buffered Time Unit (レコード最大バッファ時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Record Max Buffered Time (レコード最大バッファ時間)]​ 値の時間単位。

SECONDS

Aggregation Max Count (集約最大数)

Number (数値)

集約された Amazon Kinesis データレコードにまとめる項目の最大数。

4294967295

Aggregation Max Size (集約最大サイズ)

Number (数値)

集約された Amazon Kinesis データレコードにまとめる最大データサイズ。

51200

Aggregation Max Size Unit (集約最大サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE

  • KB

  • MB

  • GB

[Aggregation Max Size (集約最大サイズ)]​ 値のデータ単位。

BYTE

Collection Max Count (コレクション最大数)

Number (数値)

バッチ要求にまとめる項目の最大数。

500

Collection Max Size (コレクション最大サイズ)

Number (数値)

Put Record​ 操作で送信するデータの最大量。

5242880

Collection Max Size Unit (コレクション最大サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE

  • KB

  • MB

  • GB

[Collection Max Size (コレクション最大サイズ)]​ 値のデータ単位。

BYTE

Connection Timeout (接続タイムアウト)

Number (数値)

接続が失敗した場合に例外をスローする前に、コネクタと Amazon Kinesis サーバー間の TCP 接続を最初に確立するときに待機する時間。

30

Connection Timeout Unit (接続タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Timeout (接続タイムアウト)]​ 値の時間単位。

SECONDS

Max Connections (最大接続数)

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。

24

Min Connections (最小接続数)

Number (数値)

バックエンドに対して開き続ける接続の最小数。ほとんどの場合、値を増やす必要はありません。

1

Rate Limit (レート制限)

Number (数値)

シャードに送信される 1 秒あたりのデータレコード数と 1 秒あたりのバイト数を制限します。この制限により、調整に失敗する要求の送信による帯域幅と CPU サイクルの浪費を減らすことができます。デフォルト値の 150% を使用すると、1 つのプロデューサーインスタンスでシャードの許容量を完全に飽和させることができます。シャードを完全に飽和させる代わりに調整エラーを減らすには、この設定を低くすることを検討してください。

150%

Record TTL (レコード TTL)

Number (数値)

配置されるデータレコードの時間制限。この制限内に正常に配置されなかったレコードは失敗します。この値を設定するときは、データレコードが Amazon Kinesis Producer Library (KPL) から脱退した後も、ネットワークレイテンシーが発生することを考慮してください。

30

Record TTL Unit (レコード TTL 単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Record TTL (レコード TTL)]​ 値の時間単位。

SECONDS

Thread Pool Size (スレッドプールサイズ)

Number (数値)

ネイティブプロセススレッドプールの設定に使用するスレッドの最大数。デフォルト値の 0 を使用すると、KPL プロセスでスレッドプールのサイズを選択できます。

0
#### [](#接続種別)接続種別 ##### [](#Config_Connection)Kinesis Connection (Kinesis 接続) ユーザー指定のアクセスとシークレットキー、および必要に応じてロールを使用して、AWS Kinesis に接続します。これらのログイン情報によって、AWS サービスに送信される要求が安全に署名されます。 ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Proxy Configuration (プロキシ設定)

Proxy Configuration (プロキシ設定)

アウトバウンド接続のプロキシ接続設定。この設定は、​Listener​ ソースと ​Checkpoint​ 操作に適用されます。​Put Record​ 操作には影響しません。

TLS Configuration (TLS 設定)

TLS

通信に使用するプロトコル。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

この設定は、​Listener​ ソースと ​Checkpoint​ 操作に適用されます。​Put Record​ 操作には影響しません。

HTTP

Access Key (アクセスキー)

String (文字列)

Amazon が提供するアクセスキー。

x

Secret Key (シークレットキー)

String (文字列)

Amazon が提供するシークレットキー。

x

Region Endpoint (リージョンエンドポイント)

String (文字列)

トピックリージョンエンドポイント。

us-east-1

Role (ロール)

Role (ロール)

ロール設定。

Connection Timeout (接続タイムアウト)

Number (数値)

接続が失敗した場合に例外をスローする前に、コネクタと Amazon Kinesis サーバー間の TCP 接続を最初に確立するときに待機する時間。

30

Connection Timeout Time Unit (接続タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Timeout (接続タイムアウト)]​ 項目の時間単位。

SECONDS

Response Timeout (応答タイムアウト)

Number (数値)

HTTP 要求が送信されてから応答が受信されるまでの最大待機時間。

30

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 値の時間単位。

SECONDS

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
## [](#サポートされている操作)サポートされている操作 - [Checkpoint](#Checkpoint) - [Put Record](#PutRecord) ## [](#関連付けられたソース)関連付けられたソース - [Listener](#Listener) ## [](#操作)操作 ## [](#Checkpoint)Checkpoint `` Amazon DynamoDB テーブル内のリスナーの操作チェックポイント位置。フェールオーバー時に、コネクタはチェックポイント位置の後にあるレコードのフェッチを開始します。​**Checkpoint**​ 操作では、リスナーの現在の位置は変更されません。 ### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Stream Name (ストリーム名)

String (文字列)

ストリーム名。

x

Application Name (アプリケーション名)

String (文字列)

現在のストリーム位置に関するデータを保持する DynamoDB テーブルの名前。

x

Shard ID (シャード ID)

String (文字列)

シャード識別子。

Sequence Number (連番)

String (文字列)

シャード内のチェックポイントを示す連番。

Subsequence Number (サブシーケンス番号)

Number (数値)

シャード内のチェックポイントを示すサブシーケンス番号。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x
### [](#次の設定の場合)次の設定の場合 - [設定](#Config) ### [](#スロー)スロー - KINESIS:ILLEGAL\_STATE - KINESIS:INVALID\_ARGUMENT - KINESIS:PROVISIONED\_THROUGHPUT\_EXCEEDED - KINESIS:TIMEOUT - KINESIS:UNAUTHORIZED ## [](#PutRecord)Put Record `` データレコードを Amazon Kinesis データストリームに配置します。 ### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Stream Name (ストリーム名)

String (文字列)

ストリーム名。

x

Partition Key (パーティションキー)

String (文字列)

パーティションキー。指定されていない場合、コネクタによってこの値の UUID が生成されます。

Explicit Hash Key (明示的ハッシュキー)

String (文字列)

Amazon Kinesis Data Streams の explicitHashKey 値を上書きします。この値は通常、データレコードパーティションキーの MD5 関数を使用して計算されます。

Data (データ)

Any (任意)

Amazon Kinesis データストリームに配置するコンテンツ。このコンテンツの最大サイズは 1 MB です。

#[payload]

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

反復可能ストリーム機能を無効にして反復不可能ストリームを使用します。これにより、パフォーマンスオーバーヘッド、メモリ使用量、およびコストが抑えられます。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#出力)出力

型

Any (任意)
### [](#次の設定の場合-2)次の設定の場合 - [設定](#Config) ### [](#スロー-2)スロー - KINESIS:CONNECTIVITY - KINESIS:INVALID\_ARGUMENT - KINESIS:PROCESSING - KINESIS:RETRY\_EXHAUSTED - KINESIS:TIMEOUT - KINESIS:UNAUTHORIZED ## [](#ソース)ソース ## [](#Listener)Listener `` Amazon Kinesis Client Library (KCL) を使用して、ストリーム内の指定されたポイントからリスンします。
バッチサイズはさまざまであるため、チェックポイントが誤った順序で発生する可能性があり、場合によってはトランザクションの損失につながる可能性があります。トランザクションが順番に処理されるようにするには、​maxConcurrency=1​ を設定します。
### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Output Encoding (出力エンコード)

String (文字列)

この操作で出力されるペイロードのエンコード。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの実行時のみ、このリスナーをプライマリノード上で実行するかどうか。

On Capacity Overload (容量過負荷時)

Enumeration (列挙)。次のいずれかになります。

  • WAIT

  • DROP

フローが処理できる数以上のメッセージを受信した場合に Mule が適用する戦略。

WAIT

Redelivery Policy (再配信ポリシー)

Redelivery Policy (再配信ポリシー)

メッセージの再配信を処理するためのポリシー。

Stream Name (ストリーム名)

String (文字列)

ストリーム名。

x

Application Name (アプリケーション名)

String (文字列)

現在のストリーム位置に関するデータを保持する DynamoDB テーブルの名前。テーブルが存在しない場合、コネクタによって初期位置に新しいテーブルが作成されます。

x

Shard Configs (シャード設定)

Shard Config (シャード設定)​ の配列

シャード設定。指定した場合、リスナーは選択したシャードからのみリスンします。

Max Batch Size (最大バッチサイズ)

Number (数値)

バッチに含めることができるデータレコードの最大数。バッチとは、リスナーがストリームから受信するレコードの数です。

10000

Max Leases For Worker (ワーカーの最大リース数)

Number (数値)

リスナーが並行してサブスクライブできるシャードの数。

2137483647

Shard Prioritization (シャード優先度設定)

Enumeration (列挙)。次のいずれかになります。

  • PARENTS_FIRST_SHARD_PRIORITIZATION​

  • NO_OP_SHARD_PRIORITIZATION

実行前にシャードの優先度設定や絞り込みを行うために使用するロジック。

PARENTS_FIRST_SHARD_PRIORITIZATION​ 最初に親シャードの優先度を設定し、深度 (​[Max Depth (最大深度)]​ 項目) に基づいて初期化に使用できるシャードの数を制限します。

NO_OP_SHARD_PRIORITIZATION​ シャードの元のリストを変更せずに返します。

NO_OP_SHARD_PRIORITIZATION

Max Depth (最大深度)

Number (数値)

PARENTS_FIRST_SHARD_PRIORITIZATION​ シャード優先度設定オプションで使用されます。この値より深いシャードは処理から除外されます。

Read Capacity Units (読み取り容量単位)

Number (数値)

Amazon DynamoDB が ThrottlingException を返す前にコンシュームされる 1 秒あたりの厳密な一貫性読み取りの最大数。

10

Write Capacity Units (書き込み容量単位)

Number (数値)

Amazon DynamoDB が ThrottlingException を返す前にコンシュームされる 1 秒あたりの書き込みの最大数。

10

Failover Time (フェールオーバー時間)

Number (数値)

ワーカーのリースの期間。このパラメーターによって、ワーカーで処理する新しいリースが検索される頻度も決まります。頻度は指定された値の約 2 倍です。

10

Failover Time Unit (フェールオーバー時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Failover Time (フェールオーバー時間)]​ 項目の時間単位。

SECONDS

Checkpoint On Complete (完了時のチェックポイント)

Boolean (ブール)

true​ の場合、データレコードが所有フローによって処理された後に、処理が正常に完了したかどうかを考慮せずに、リスナーは Amazon DynamoDB に現在の読み取り位置をチェックポイント設定します。

true

Absolute Position (絶対位置)

Enumeration (列挙)。次のいずれかになります。

  • LATEST

  • FIRST

リスナーが最新のデータレコードまたは最も古いデータレコードのどちらからリスンするか。

Timestamp (タイムスタンプ)

DateTime

リスナーがリスンする日時。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#出力-2)出力

型

[​Record Attributes (レコード属性)​] でのバイナリメッセージの配列。
### [](#次の設定の場合-3)次の設定の場合 - [設定](#Config) ## [](#型)型 ### [](#ProxyConfiguration)Proxy Configuration (プロキシ設定)
項目 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

プロキシ要求が送信されるホスト。

x

Port (ポート)

Number (数値)

プロキシ要求が送信されるポート。

x

Username (ユーザー名)

String (文字列)

プロキシに対して認証するユーザー名。

Password (パスワード)

String (文字列)

プロキシに対して認証するパスワード。

Non Proxy Hosts (非プロキシホスト)

Array of String (文字列の配列)

プロキシを使用してはならないホストのリスト。

Ntlm Domain (NTLM ドメイン)

String (文字列)

プロキシに対して認証するドメイン。
### [](#Tls)TLS
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

Trust Store (トラストストア)

トラストストア

Key Store (キーストア)

Key Store (キーストア)

Revocation Check (取り消し確認)
### [](#TrustStore)トラストストア
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

使用するストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用するアルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true​ に設定した場合、証明書の検証が行われず、接続が攻撃に対して脆弱になります。各自の責任で使用してください。
### [](#KeyStore)Key Store (キーストア)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Type (型)

String (文字列)

使用するストアの型。

Alias (別名)

String (文字列)

キーストアに多数の非公開キーがある場合、この属性は、使用するキーの別名を示します。定義しない場合、ファイルにある最初のキーがデフォルトで使用されます。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用するアルゴリズム。
### [](#StandardRevocationCheck)Standard Revocation Check (標準の取り消し確認)
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーンの最後の要素のみを確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

最初に OCSP ではなく CRL を試みます。

No Fallback (代替なし)

Boolean (ブール)

第 2 の確認方法を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に認定エラーを回避します。
### [](#CustomOcspResponder)Custom Ocsp Responder (カスタム Ocsp レスポンダー)
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。
### [](#CrlFile)Crl File (Crl ファイル)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。
### [](#Role)Role (ロール)
項目 型 説明 デフォルト値 必須

Arn

String (文字列)

前提とするロールの Amazon リソース名 (ARN)。

x

External Id (外部 ID)

String (文字列)

別のアカウントのロールを前提とするときに必要な可能性がある一意の識別子。ロールが属するアカウントの管理者が外部 ID を提供している場合、この項目にその値を入力します。

Duration (所要時間)

Number (数値)

ロールセッションの期間。

3600

Duration Time Unit (期間の時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Duration (所要時間)]​ 項目の時間単位。

SECONDS

Referred Policy Arns (参照されるポリシー ARN)

Array of String (文字列の配列)

管理セッションポリシーとして使用する IAM 管理ポリシーの Amazon リソース名 (ARN)。 ポリシーは、ロールと同じアカウントに存在する必要があります。

タグ

Object (オブジェクト)

渡すセッションタグのリスト。各セッションタグは、キー名および関連する値で構成されます。
### [](#Reconnection)Reconnection (再接続)
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。
### [](#Reconnect)Reconnect (再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

Count (数)

Number (数値)

再接続の試行回数。
### [](#ReconnectForever)Reconnect Forever (繰り返し再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。
### [](#RecordAttributes)Record Attributes (レコード属性)
項目 型 説明 デフォルト値 必須

Aggregated (集約済み)

Boolean (ブール)

おおよその到着タイムスタンプ。

String (文字列)

Encryption Type (暗号化種別)

String (文字列)

Partition Key (パーティションキー)

String (文字列)

Partition Key (パーティションキー)

String (文字列)

Sequence Number (連番)

String (文字列)

Shard Id (シャード ID)

String (文字列)

Sub Sequence Number (サブシーケンス番号)

Number (数値)
### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー)
項目 型 説明 デフォルト値 必須

Max Redelivery Count (最大再配信数)

Number (数値)

プロセス失敗メッセージをトリガーするまでに、正常に処理されないメッセージを再配信できる最大回数。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

使用するセキュアハッシュアルゴリズム。

SHA-256

Message Identifier (メッセージ識別子)

Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子)

メッセージを識別するために使用される戦略。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストア。
### [](#RedeliveryPolicyMessageIdentifier)Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子)
項目 型 説明 デフォルト値 必須

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用するかどうか。

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​false​ の場合にのみ設定できます。
### [](#ShardConfig)Shard Config (シャード設定)
項目 型 説明 デフォルト値 必須

Shard Id (シャード ID)

String (文字列)

シャード識別子。

x

Shard Initial Position (シャードの初期位置)

Shard Initial Position (シャードの初期位置)

シャードの初期位置。

x
### [](#ShardInitialPosition)Shard Initial Position (シャードの初期位置)
項目 型 説明 デフォルト値 必須

At Sequence Number (連番の位置)

String (文字列)

リスナーは、データストリームのこの位置でリスンを開始します。

After Sequence Number (連番の後)

String (文字列)

リスナーは、データストリームのこの位置の後にリスンを開始します。

Absolute Position (絶対位置)

Enumeration (列挙)。次のいずれかになります。

  • LATEST

  • FIRST

リスナーは、値に応じて最新または最も古いレコードからリスンを開始します。

Timestamp (タイムスタンプ)

DateTime
### [](#RepeatableInMemoryStream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム)
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

ストリームをコンシュームしてランダムにアクセスするために割り当てられるメモリ量。ストリームのデータ量がこのバッファサイズを超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ 値に従って、​[Max In Memory Size (最大メモリ内サイズ)]​ 値を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE

  • KB

  • MB

  • GB

この表内の項目が表現される単位。
### [](#RepeatableFileStoreStream)Repeatable File Store Stream (反復可能なファイルストアストリーム)
項目 型 説明 デフォルト値 必須

In Memory Size (メモリ内サイズ)

Number (数値)

データをメモリ内に保持するためにストリームで使用する最大メモリ。これを超えると、ディスクのコンテンツがバッファされます。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 値で表される単位。
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [参照](#) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)