Connectorメッセージ処理プロパティ

max.batch.size

タイプ: int

説明:
プロセシングのためにバッチするシンク レコードの最大数。

以下のレコードを含むバッチするを考慮します。

[ 1, 2, 3, 4, 5 ]

0に設定すると、コネクターはバッチ全体に対して1回のバルク書き込みを実行します。

1に設定すると、コネクターはバッチ内の各レコードに対して1回のバルク書き込みを実行します。次の例に示すように、合計5回のバルク書き込みが実行されます。

[1], [2], [3], [4], [5]

デフォルト: 0
許容値: 整数

bulk.write.ordered

タイプ: ブール値

説明:
コネクターがレコードのバッチを順序付きの一括書き込み操作として書き込むか、順序付きでない一括書き込み操作として書き込むかを示します。true に設定すると、デフォルト値であるため、コネクターはレコードのバッチを順序付きの一括書き込み操作として書き込みます。

一括書き込み操作の詳細については、「一括書き込み操作」を参照してください。

デフォルト: true
受け入れる値: true または false

rate.limit. Bying.n

型: int

説明:
シンクコネクターがレート制限タイムアウトをtriggerするために処理するレコードのバッチ数。値が 0 の場合、レート制限はありません。

デフォルト: 0
受け入れる値: 整数

rate.limiting.timeout

タイプ: int

説明:
レート制限のしきいちに達した後、シンク コネクターがプロセシングを再開するまでの待機時間(ミリ秒)。

デフォルト: 0
受け入れ可能な値: 整数

Task.max

タイプ: int

説明:
このコネクターで作成するタスクの最大数。コネクターは、指定された最大タスク数より少ない数のタスクを作成する場合があります。指定された並列化レベルを取り扱えない場合。

重要: 1 より大きい値を指定する場合、コネクターはタスクの並列プロセシングを有効にします。トピックに複数のパーティション ログがある場合、これによりコネクターはトピックからメッセージを並列で読み取ることができますが、タスクはメッセージを順序に処理できない場合があります。

デフォルト: 1
受け入れ可能な値: 整数