Kinesis Firehose putRecord vs putRecordBatch

Question

Я использую Java API для Kinesis Firehose и использую putRecordBatch(), где это возможно. Однако в моем приложении я иногда отправляю только одну запись и не могу позволить себе ждать больше или кэшировать ее в памяти.

Однако мой код немного сложнее, чем я хочу, потому что я отслеживаю количество успешных/неудачных попыток для каждой операции. putRecordBatch возвращает int, представляющий количество неудачных отправлений из набора отправленных записей, например. 2 из 4 сбоев, тогда как putRecord() либо преуспевает, либо генерирует исключение.

Я бы предпочел просто использовать putRecordBatch() всюду, но документ говорит, что использовать его только если у вас есть несколько записей для отправки.

Это может быть немного длинным выстрелом, но кто-нибудь здесь имеет опыт работы с этим API, в частности эти методы? Вы сделали то, что я созерцаю, и просто использовали putRecordBatch() повсюду, даже с набором записей из 1?

Answer 1

Я настроил именно то, что вы описываете: ситуация, которая обычно отправляет пакетные звонки, но иногда посылает только одну запись с помощью putRecordBatch(). По моему пониманию документов, похоже, что они только уточняют, что если вы хотите просто отправить одну запись, вы должны использовать putRecord, в отличие от фактического указания этого. Из преимуществ производительности я вижу использование только putRecordBatch() - который отлично работает, если вам нужно отправить 1 запись, кстати - я уверен, что вы должны быть в порядке использовать putRecordBatch() для всех отправлений.