Kinesis Firehose putRecordとputRecordBatch

Question

私はKinesis Firehose用のJava APIを使用しており、可能であればputRecordBatch（）を利用しています。しかし、私のアプリケーションでは、たまにレコードを1つだけ送信することがあり、メモリを待つ余裕がありません。

しかし、私のコードは、私が各操作の成功/失敗の数を追跡しているので、それよりも少し複雑です。 putRecordBatchは、送信されたレコードのセットから失敗したサブミットの数を表すintを返します。 putRecord（）が成功するか、例外をスローするのに対して、2つの失敗は2つです。

私はどこでもputRecordBatch（）を使用したいと思いますが、ドキュメントには複数のレコードを送信する必要がある場合にのみ使用するように指定されています。

これは少し長めのことかもしれませんが、ここで誰もこのAPIの経験がありますか？具体的にはこれらの方法はありますか？あなたが思っていることをやって、putRecordBatch（）をどこでも使ったことがありますか？レコードセットが1であっても？

Answer 1

説明しているものを正確に設定しました。通常、バッチコールを送信するが、時にはputRecordBatch（）を使用して1つのレコードしか送信しない状況です。ドキュメントの私の理解から、あなたはただ一つのレコードを送信したい場合、実際にそれを要求するのではなく、putRecordを使用するべきであることを明確にしているようです。私がputRecordBatch（）を使用して見ているパフォーマンス上の利点から、1レコードを送信する必要がある場合はうまく動作します。すべての送信にputRecordBatch（）を使用することが大丈夫であると確信しています。