AmazonKinesisClient getRecord() 和 IRecordProcessor processRecords() 之间的区别
Difference between AmazonKinesisClient getRecord() AND IRecordProcessor processRecords()
从 aws kinesis 流读取记录时有什么区别
AmazonKinesisClient
方法 getRecord()
AND IRecordProcessor
接口的方法 processRecords()
.
由于IRecordProcessor
的processRecords()
是用来处理stream中的记录的,而AmazonKinesisClient
的getRecords()
只是用来获取记录的,显然我们可以在获取到数据后进行处理记录。
但是这些获取记录的不同方法的主要区别或用例是什么?
我们还有什么方法可以获取使用 AmazonKinesisClient
处理的记录。
getRecords
是对 GetRecords 的 AWS API 级调用,属于 Java.
的官方 AWS Java SDK
相比之下,processRecords
是 Kinesis 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.
从 aws kinesis 流读取记录时有什么区别
AmazonKinesisClient
方法 getRecord()
AND IRecordProcessor
接口的方法 processRecords()
.
由于IRecordProcessor
的processRecords()
是用来处理stream中的记录的,而AmazonKinesisClient
的getRecords()
只是用来获取记录的,显然我们可以在获取到数据后进行处理记录。
但是这些获取记录的不同方法的主要区别或用例是什么?
我们还有什么方法可以获取使用 AmazonKinesisClient
处理的记录。
getRecords
是对 GetRecords 的 AWS API 级调用,属于 Java.
相比之下,processRecords
是 Kinesis 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.