AmazonKinesisClient getRecord() 和 IRecordProcessor processRecords() 之间的区别

Difference between AmazonKinesisClient getRecord() AND IRecordProcessor processRecords()

从 aws kinesis 流读取记录时有什么区别

AmazonKinesisClient 方法 getRecord() AND IRecordProcessor 接口的方法 processRecords().

由于IRecordProcessorprocessRecords()是用来处理stream中的记录的,而AmazonKinesisClientgetRecords()只是用来获取记录的,显然我们可以在获取到数据后进行处理记录。

但是这些获取记录的不同方法的主要区别或用例是什么?

我们还有什么方法可以获取使用 AmazonKinesisClient 处理的记录。

getRecords 是对 GetRecords 的 AWS API 级调用,属于 Java.

的官方 AWS Java SDK

相比之下,processRecordsKinesis Client Library 的一部分,Kinesis Client Library 是一个独立的、更高级别的库,用于与 Kinesis 交互:

KCL helps you consume and process data from a Kinesis data stream by taking care of many of the complex tasks associated with distributed computing. These include load balancing across multiple consumer application instances, responding to consumer application instance failures, checkpointing processed records, and reacting to resharding.