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

max.batch.size

タイプ: int

説明:
処理のためにバッチするする Sink レコードの最大数。次のレコードを含むバッチするを考えてみましょう。

[ 1, 2, 3, 4, 5 ]

0に設定すると、コネクタはバッチする全体に対して

11 つの一括書込みを実行します。 に設定すると、コネクタはバッチする内の各レコードに対して 1 回の一括書込みを実行し、合計 5 つの一括書込みを行います（次の例に示すように）。

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

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

bulk.write.ordered

タイプ:ブール値値 説明:コネクタがレコードのバッチするを順序付きまたは順序なし一括書き込み操作として書き込みます。デフォルト値である


に設定すると、コネクタは順序付き一括書込み操作としてレコードのバッチするを書込みます。一括書込み(write)true

操作の詳細については、「 一括書込み (write) 操作

」を参照してください。デフォルト:true
許容値:true またはfalse

rate.limit. Bying.n

タイプ: int

説明:
レート制限タイムアウトをトリガーするために Sink コネクタが処理するレコードのバッチ数。 の値は、レート制限がないことを意味します。デフォルト:0

0
許容値: 整数

rate.limiting.timeout

タイプ: int

説明:
レート制限のしきい値に達した後、Sink コネクタ が処理を再開するまでに待機する時間（ミリ秒単位）。デフォルト:

0
許容値: 整数

Task.max

タイプ: int

説明:
このコネクタに対して作成するタスクの最大数。指定された並列処理レベルを処理できない場合は、指定された最大数よりも少ないコネクタを作成することがあります。重要:

1より大きい値を指定すると、コネクタはタスクの並列処理を有効にします。トピックに複数のパーティション

ログがあり、コネクタがトピックから並列に読み取ることができる場合、タスクはメッセージを正しい順序で処理しない可能性があります。デフォルト:1
許容値: 整数