我正在使用Java API for Kinesis Firehose,并在可能的情况下使用putRecordBatch()。然而,在我的应用程序中,我偶尔只发送一条记录,无法等待更多记录或将其缓存到内存中。
然而,我的代码比我希望的要复杂一些,因为我在跟踪每个操作的成功/失败计数。putRecordBatch返回一个整数,表示发送的一组记录提交失败的次数,例如,2次失败,4次失败,而putRecord()要么成功,要么抛出异常。
我更喜欢在任何地方都使用putRecordBatch(),但是文档说只有在有多个记录要提交时才使用它。
这可能有点冒险,但是在座的任何人都有使用这个API,特别是这些方法的经验吗?您是否做了我正在考虑的事情,并且在所有地方都使用了putRecordBatch(),即使创纪录的值是1?
https://stackoverflow.com/questions/41293293
复制相似问题